24#ifndef OMNIEVENTS__PROXYPUSHCONSUMER_H
25#define OMNIEVENTS__PROXYPUSHCONSUMER_H
44#include "CosEventChannelAdmin.hh"
46#ifdef HAVE_STD_IOSTREAM
61:
public virtual POA_CosEventChannelAdmin::ProxyPushConsumer,
94 CosEventChannelAdmin::ProxyPushConsumer_ptr
createObject();
128#if OMNIEVENTS__DEBUG_SERVANT
#define OMNIEVENTS__DEBUG_REF_COUNTS__DECL
Declares debug versions of _add/remove_ref().
T::_ptr_type createNarrowedReference(PortableServer::POA_ptr poa, const char *repositoryId)
Helper method that creates a new CORBA object and then narrows it to the appropriate type.
Interface for classes that wish to receive callbacks from deferred requests.
Default servant for ProxyPushConsumer objects.
void disconnect_push_consumer()
We may not have a record of the supplier, so this method must accept calls from any supplier without ...
list< CORBA::Any * > & _queue
ConsumerAdmin_i & _consumerAdmin
CORBA::String_var _channelName
Connections_t _connections
virtual ~ProxyPushConsumer_i()
void push(const CORBA::Any &event)
Accepts events from any supplier, not just those stored in _connections.
string currentObjectId() const
void output(ostream &os) const
Save this object's state to a stream.
CosEventChannelAdmin::ProxyPushConsumer_ptr createObject()
Constructs a new object.
bool _useLocalQueue
Switch between RT/chunked modes.
void reincarnate(const PersistNode &node)
Re-create all servants from information saved in the log file.
void disconnect()
Send disconnect_push_supplier() to all connected PushSuppliers.
void connect_push_supplier(CosEventComm::PushSupplier_ptr pushSupplier)
If pushSupplier is provided, then it is stored in _connections.
map< string, Connection * > Connections_t
bool _targetIsProxy
TRUE if _target is a ProxyPushSupplier.
OMNIEVENTS__DEBUG_REF_COUNTS__DECL void callback(CORBA::Request_ptr req)
Sets _targetIsProxy, if it is.
Connection()
NO IMPLEMENTATION.
const char * _channelName
CosEventComm::PushSupplier_var _target
void output(ostream &os) const
Save this object's state to a stream.