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 が保持するコンシューマに対してデータを書き込む。
|
release
protected Logbuf rtcout
public void destruct()
当該Publisherが不要となり破棄される際に、PublisherFactoryにより呼び出されます。
protected void finalize() throws java.lang.Throwable
ファイナライザです。
finalize
クラス内 java.lang.Object
java.lang.Throwable
public ReturnCode init(Properties prop)
init
initialization
init
クラス内 PublisherBase
prop
- public ReturnCode setConsumer(InPortConsumer consumer)
setConsumer
Store InPort consumer
setConsumer
クラス内 PublisherBase
consumer
- public ReturnCode setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
setBuffer
Setting buffer
setBuffer
クラス内 PublisherBase
buffer
- public ReturnCode setListener(ConnectorBase.ConnectorInfo info, ConnectorListeners listeners)
Setting buffer pointer
setListener
クラス内 PublisherBase
public 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
クラス内 PublisherBase
data
- 書き込むデータ
sec
- タイムアウト時間
usec
- タイムアウト時間
public ReturnCode write(org.omg.CORBA.portable.OutputStream data)
write
クラス内 PublisherBase
public boolean isActive()
write
isActive
クラス内 PublisherBase
public ReturnCode activate()
activate
activate
クラス内 PublisherBase
public ReturnCode deactivate()
deactivate
deactivate
クラス内 PublisherBase
public PublisherBase creator_()
creator_
creator_
インタフェース内 ObjectCreator<PublisherBase>
public void destructor_(java.lang.Object obj)
destructor_
destructor_
インタフェース内 ObjectDestructor
obj
- The target instances for destructionpublic static void PublisherFlushInit()
PublisherFlushInit
public java.lang.String getName()
getName
getName
クラス内 PublisherBase
protected 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)