public class PublisherFlush extends PublisherBase implements ObjectCreator<PublisherBase>, ObjectDestructor
データ送出を待つコンシューマを、送出する側と同じスレッドで動作させる場合に使用します。
| コンストラクタと説明 | 
|---|
PublisherFlush()
コンストラクタ
  
 | 
| 修飾子とタイプ | メソッドと説明 | 
|---|---|
ReturnCode | 
activate()
 activate  
 | 
PublisherBase | 
creator_()
 creator_  
 | 
ReturnCode | 
deactivate()
 deactivate  
 | 
void | 
destruct()
当該Publisherが不要となり破棄される際に、PublisherFactoryにより呼び出されます。 
 | 
void | 
destructor_(java.lang.Object obj)
 destructor_  
 | 
protected void | 
finalize()
ファイナライザです。 
 | 
java.lang.String | 
getName()
 getName  
 | 
ReturnCode | 
init(Properties prop)
 init 
  initialization  
 | 
boolean | 
isActive()
 write  
 | 
protected void | 
onReceived(org.omg.CORBA.portable.OutputStream data)  | 
protected void | 
onReceiverError(org.omg.CORBA.portable.OutputStream data)  | 
protected void | 
onReceiverFull(org.omg.CORBA.portable.OutputStream data)  | 
protected void | 
onReceiverTimeout(org.omg.CORBA.portable.OutputStream data)  | 
protected void | 
onSend(org.omg.CORBA.portable.OutputStream data)
 Connector data listener functions  
 | 
static void | 
PublisherFlushInit()
 PublisherFlushInit  
 | 
ReturnCode | 
setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
 setBuffer 
  Setting buffer  
 | 
ReturnCode | 
setConsumer(InPortConsumer consumer)
 setConsumer 
  Store InPort consumer  
 | 
ReturnCode | 
setListener(ConnectorBase.ConnectorInfo info,
           ConnectorListeners listeners)
 Setting buffer pointer  
 | 
ReturnCode | 
write(org.omg.CORBA.portable.OutputStream data)  | 
ReturnCode | 
write(org.omg.CORBA.portable.OutputStream data,
     int sec,
     int usec)
データを書き込む
 
 
 {@.ja Publisher が保持するコンシューマに対してデータを書き込む。 
 | 
releaseprotected Logbuf rtcout
public void destruct()
当該Publisherが不要となり破棄される際に、PublisherFactoryにより呼び出されます。
protected void finalize()
                 throws java.lang.Throwable
ファイナライザです。
finalize クラス内 java.lang.Objectjava.lang.Throwablepublic ReturnCode init(Properties prop)
init
initialization
init クラス内 PublisherBaseprop - public ReturnCode setConsumer(InPortConsumer consumer)
setConsumer
Store InPort consumer
setConsumer クラス内 PublisherBaseconsumer - public ReturnCode setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
setBuffer
Setting buffer
setBuffer クラス内 PublisherBasebuffer - public ReturnCode setListener(ConnectorBase.ConnectorInfo info, ConnectorListeners listeners)
Setting buffer pointer
setListener クラス内 PublisherBasepublic ReturnCode write(org.omg.CORBA.portable.OutputStream data, int sec, int usec)
Publisher が保持するコンシューマに対してデータを書き込む。コン シューマ、リスナ等が適切に設定されていない等、Publisher オブジェ クトが正しく初期化されていない場合、この関数を呼び出すとエラーコー ド PRECONDITION_NOT_MET が返され、コンシューマへの書き込み等の操 作は一切行われない。 コンシューマへの書き込みに対して、コンシューマがフル状態、コン シューマのエラー、コンシューマへの書き込みがタイムアウトした場合 にはそれぞれ、エラーコード SEND_FULL, SEND_ERROR, SEND_TIMEOUT が返される。 これら以外のエラーの場合、PORT_ERROR が返される。
write クラス内 PublisherBasedata - 書き込むデータ
   sec - タイムアウト時間
   usec - タイムアウト時間
   public ReturnCode write(org.omg.CORBA.portable.OutputStream data)
write クラス内 PublisherBasepublic boolean isActive()
write
isActive クラス内 PublisherBasepublic ReturnCode activate()
activate
activate クラス内 PublisherBasepublic ReturnCode deactivate()
deactivate
deactivate クラス内 PublisherBasepublic PublisherBase creator_()
creator_
creator_ インタフェース内 ObjectCreator<PublisherBase>public void destructor_(java.lang.Object obj)
destructor_
destructor_ インタフェース内 ObjectDestructorobj - The target instances for destructionpublic static void PublisherFlushInit()
PublisherFlushInit
public java.lang.String getName()
getName
getName クラス内 PublisherBaseprotected void onSend(org.omg.CORBA.portable.OutputStream data)
Connector data listener functions
protected void onReceived(org.omg.CORBA.portable.OutputStream data)
protected void onReceiverFull(org.omg.CORBA.portable.OutputStream data)
protected void onReceiverTimeout(org.omg.CORBA.portable.OutputStream data)
protected void onReceiverError(org.omg.CORBA.portable.OutputStream data)