public class InPortDirectConsumer extends java.lang.Object implements InPortConsumer, ObjectCreator<InPortConsumer>, ObjectDestructor
This is an implementation class of the input port Consumer
that uses CORBA for means of communication. The InPort consumer class which uses the OpenRTM::InPortCdr interface in CORBA for data transfer and realizes a push-type dataflow.Constructor and Description |
---|
InPortDirectConsumer()
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected ReturnCode |
convertReturn(PortStatus status)
Converts PortStatus into ReturnCode.
|
InPortConsumer |
creator_()
Creats InPortDirectConsumer
|
void |
destructor_(java.lang.Object obj)
Destructs Object
|
void |
init(Properties prop)
Initializing configuration
|
static void |
InPortDirectConsumerInit()
Module initialization
|
void |
publishInterfaceProfile(NVListHolder properties)
Publish InterfaceProfile information
|
ReturnCode |
put(org.omg.CORBA.portable.OutputStream data)
Send data to the destination port
|
void |
setConnector(OutPortConnector connector)
set Connector
|
boolean |
subscribeInterface(NVListHolder properties)
Subscribe to the data sending notification
|
void |
unsubscribeInterface(NVListHolder properties)
Unsubscribe the data send notification
|
public InPortDirectConsumer()
buffer 当該コンシューマに割り当てるバッファオブジェクト buffer The buffer object that is attached to this Consumer
public void init(Properties prop)
This operation would be called to configure in initialization. In the concrete class, configuration should be performed getting appropriate information from the given Properties data. This function might be called right after instantiation and connection sequence respectivly. Therefore, this function should be implemented assuming multiple call.
init
in interface InPortConsumer
prop
-
Configuration informationpublic ReturnCode put(org.omg.CORBA.portable.OutputStream data)
Pure virtual function to send data to the destination port. This function might the following return codes
put
in interface InPortConsumer
data
-
Data sent by this operation.public void publishInterfaceProfile(NVListHolder properties)
Publish interfaceProfile information. Check the dataport.interface_type value of the NameValue object specified by an argument in property information and get information only when the interface type of the specified port is matched.
publishInterfaceProfile
in interface InPortConsumer
properties
-
Properties to get InterfaceProfile informationpublic boolean subscribeInterface(NVListHolder properties)
Subscribe to the data sending notification based on specified property information.
subscribeInterface
in interface InPortConsumer
properties
-
Information for subscriptionpublic void unsubscribeInterface(NVListHolder properties)
Unsubscribe the data send notification.
unsubscribeInterface
in interface InPortConsumer
properties
-
Information for unsubscriptionprotected ReturnCode convertReturn(PortStatus status)
status
-
PortStatuspublic InPortConsumer creator_()
creator_
in interface ObjectCreator<InPortConsumer>
public void destructor_(java.lang.Object obj)
destructor_
in interface ObjectDestructor
obj
-
The target instances for destructionpublic static void InPortDirectConsumerInit()
This initialization function registers InPortDirectConsumer's factory.
public void setConnector(OutPortConnector connector)
setConnector
in interface InPortConsumer
connector
-
OutPortConnector