C++ Based OPC UA Client/Server/PubSub SDK  1.7.6.537
Public Member Functions | Protected Member Functions | List of all members
PubSubServer::DataSetDispatcher Class Reference

Class DataSetDispatcher. More...

#include <datasetdispatcher.h>

Inherits PubSubBase::DataSetReaderCallback, ReferenceCounter, and PubSubReceiveQueueAccess.

Public Member Functions

 DataSetDispatcher (PubSubBase::DataSetReader *pDataSetReader, DataSetDispatcherCallback *pDispatcherCallback, PubSubDataSetDispatcherCallback *pPubSubDataSetDispatcherCallback)
 Creates an instance of the DataSetDispatcher.
 
virtual OpcUa_StatusCode startUpReader (PubSubBase::DataSetReader *)
 Callback informing the application about the start up of the PubSub module in the server SDK.
 
virtual OpcUa_StatusCode shutDownReader (PubSubBase::DataSetReader *)
 Callback informing the application about the shut down of the PubSub module in the server SDK. More...
 
virtual OpcUa_StatusCode newMessageReceived (PubSubBase::DataSetReader *, struct ua_decoder_context *, struct pubsub_datasetmsg_ctx *)
 Callback informing about a new message received for a DataSetReader. More...
 
virtual void newDataInQueue (PubSubBase::DataSetReader *pDataSetReader, OpcUa_UInt16 status, ua_datetime timestamp)
 Callback informing about new data in the queue. More...
 
virtual bool getValueFromQueue (OpcUa_UInt32 index, OpcUa_DataValue &dataValue)
 Method used to get the value of a receive queue item. More...
 
- Public Member Functions inherited from PubSubBase::DataSetReaderCallback
virtual void stateChange (PubSubBase::DataSetReader *pDataSetReader, OpcUa_PubSubState newState)
 Callback informing the application about a state change of the DataSetReader. More...
 
- Public Member Functions inherited from ReferenceCounter
 ReferenceCounter ()
 construction
 
virtual ~ReferenceCounter ()
 destruction
 

Protected Member Functions

virtual ~DataSetDispatcher ()
 Destroys the ReaderQueueItem object.
 

Detailed Description

Class DataSetDispatcher.

Member Function Documentation

bool PubSubServer::DataSetDispatcher::getValueFromQueue ( OpcUa_UInt32  index,
OpcUa_DataValue &  dataValue 
)
virtual

Method used to get the value of a receive queue item.

Returns true if the queue index is valid and false if the index is invalid.

Implements PubSubReceiveQueueAccess.

void PubSubServer::DataSetDispatcher::newDataInQueue ( PubSubBase::DataSetReader *  pDataSetReader,
OpcUa_UInt16  status,
ua_datetime  timestamp 
)
virtual

Callback informing about new data in the queue.

This callback is used if the application takes the values from a value queue filled by the PubSubstack when a received message is decoded by the PubSub stack

The method should not block

Reimplemented from PubSubBase::DataSetReaderCallback.

virtual OpcUa_StatusCode PubSubServer::DataSetDispatcher::newMessageReceived ( PubSubBase::DataSetReader *  pDataSetReader,
struct ua_decoder_context *  pDecoder,
struct pubsub_datasetmsg_ctx *  pDataSetMessageContext 
)
inlinevirtual

Callback informing about a new message received for a DataSetReader.

This callback ist used if the application decodes the received message.

The method should not block

Implements PubSubBase::DataSetReaderCallback.

virtual OpcUa_StatusCode PubSubServer::DataSetDispatcher::shutDownReader ( PubSubBase::DataSetReader *  pDataSetReader)
inlinevirtual

Callback informing the application about the shut down of the PubSub module in the server SDK.

The application is not allowed to call any methods on the PubSubModule if this method call is returned.

Implements PubSubBase::DataSetReaderCallback.

The documentation for this class was generated from the following files: