public class PublisherFlush extends PublisherBase implements ObjectCreator<PublisherBase>, ObjectDestructor
データ送出を待つコンシューマを、送出する側と同じスレッドで動作させる場合に使用します。
Constructor and Description |
---|
PublisherFlush()
Constructor
|
Modifier and Type | Method and Description |
---|---|
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
|
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
|
ReturnCode |
setConsumer(InPortConsumer consumer)
setConsumer
|
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)
Write data
|
release
protected Logbuf rtcout
public void destruct()
当該Publisherが不要となり破棄される際に、PublisherFactoryにより呼び出されます。
protected void finalize() throws java.lang.Throwable
ファイナライザです。
finalize
in class java.lang.Object
java.lang.Throwable
public ReturnCode init(Properties prop)
init
initialization
init
in class PublisherBase
prop
- public ReturnCode setConsumer(InPortConsumer consumer)
setConsumer
Store InPort consumer
setConsumer
in class PublisherBase
consumer
- public ReturnCode setBuffer(BufferBase<org.omg.CORBA.portable.OutputStream> buffer)
setBuffer
Setting buffer
setBuffer
in class PublisherBase
buffer
- public ReturnCode setListener(ConnectorBase.ConnectorInfo info, ConnectorListeners listeners)
Setting buffer pointer
setListener
in class PublisherBase
public ReturnCode write(org.omg.CORBA.portable.OutputStream data, int sec, int usec)
This function writes data into the consumer associated with this Publisher. If this function is called without initializing correctly such as a consumer, listeners, etc., error code PRECONDITION_NOT_MET will be returned and no operation of the writing to the consumer etc. will be performed. When publisher writes data to the buffer, if the consumer returns full-status, returns error, is returned with timeout, error codes BUFFER_FULL, BUFFER_ERROR and BUFFER_TIMEOUT will be returned respectively. In other cases, PROT_ERROR will be returned.
write
in class PublisherBase
data
-
Data to be wrote to the buffersec
-
Timeout time in unit secondsusec
-
Timeout time in unit micro-secondspublic ReturnCode write(org.omg.CORBA.portable.OutputStream data)
write
in class PublisherBase
public boolean isActive()
write
isActive
in class PublisherBase
public ReturnCode activate()
activate
activate
in class PublisherBase
public ReturnCode deactivate()
deactivate
deactivate
in class PublisherBase
public PublisherBase creator_()
creator_
creator_
in interface ObjectCreator<PublisherBase>
public void destructor_(java.lang.Object obj)
destructor_
destructor_
in interface ObjectDestructor
obj
- The target instances for destructionpublic static void PublisherFlushInit()
PublisherFlushInit
public java.lang.String getName()
getName
getName
in class 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)