39 #ifndef ORO_MQ_TEMPATE_PROTOCOL_BASE_HPP 40 #define ORO_MQ_TEMPATE_PROTOCOL_BASE_HPP 43 #include "../../types/TypeMarshaller.hpp" 46 #include <boost/type_traits/has_virtual_destructor.hpp> 47 #include <boost/static_assert.hpp> 78 }
catch(std::exception& e) {
79 log(
Error) <<
"Failed to create MQueue Channel element: " << e.what() << endlog();
For each transportable type T, specify the conversion functions.
base::ChannelElementBase::shared_ptr buildDataStorage(ConnPolicy const &policy) const
Creates single data or buffered storage for this type.
Implements the a ChannelElement using message queues.
A connection policy object describes how a given connection should behave.
Objects implementing this interface have the capability to convert data sources to and from a binary ...
static const types::TypeInfo * getTypeInfo()
Return the typeinfo object.
T UserType
The given T parameter is the type for reading DataSources.
boost::intrusive_ptr< ChannelElementBase > shared_ptr
Contains TaskContext, Activity, OperationCaller, Operation, Property, InputPort, OutputPort, Attribute.
The base class of every data flow port.
virtual base::ChannelElementBase::shared_ptr createStream(base::PortInterface *port, const ConnPolicy &policy, bool is_sender) const
Creates a streaming channel element for reading or writing over this transport.