EngineConnection encapsulates the information related to a connection between two Apama messaging components.
More...
#include <engine_client_cpp.hpp>
EngineConnection encapsulates the information related to a connection between two Apama messaging components.
◆ EngineConnection() [1/2]
com::apama::engine::EngineConnection::EngineConnection |
( |
const char * |
host, |
|
|
int |
port, |
|
|
bool |
disconnectSlow, |
|
|
EngineManagement::ConnectMode |
connectMode, |
|
|
const char *const * |
channels |
|
) |
| |
|
inline |
- Parameters
-
host | The remote host to connect to |
port | The remote port to connect to |
disconnectSlow | Whether we should be disconnected if we don't keep up. |
connectMode | the connection mode to use. Set to CONNECT_LEGACY for single connection, all events delivered to the default channel. Set to CONNECT_PARALLEL for connection per channel and channel values passed through. |
channels | An array of names representing the channels to subscribe to. This is a null-terminated array of pointers to zero-terminated char arrays. If this is null or empty, subscribe to all channels. Note that these channel names should be encoded in UTF-8. |
◆ EngineConnection() [2/2]
com::apama::engine::EngineConnection::EngineConnection |
( |
const char * |
host, |
|
|
int |
port, |
|
|
const char *const * |
channels |
|
) |
| |
|
inline |
- Parameters
-
host | The remote host to connect to |
port | The remote port to connect to |
channels | An array of names representing the channels to subscribe to. This is a null-terminated array of pointers to zero-terminated char arrays. If this is null or empty, subscribe to all channels. Note that these channel names should be encoded in UTF-8. |
◆ ~EngineConnection()
virtual com::apama::engine::EngineConnection::~EngineConnection |
( |
| ) |
|
|
inlinevirtual |
Destroy the underlying connection data.
◆ getChannels()
virtual const std::vector<std::string>& com::apama::engine::EngineConnection::getChannels |
( |
| ) |
const |
|
inlinevirtual |
Get the channels associated with this connection.
- Returns
- The list of channels that the downstream component should listen to.
◆ getConnectMode()
Get the connection mode associated with this connection.
- Returns
- The connection mode associated with this connection.
◆ getDisconnectSlow()
virtual bool com::apama::engine::EngineConnection::getDisconnectSlow |
( |
| ) |
const |
|
inlinevirtual |
Get the value of disconnectSlow flag associated with this connection.
- Returns
- returns true if we should be disconnected if this connection is slow.
◆ getHost()
virtual const std::string& com::apama::engine::EngineConnection::getHost |
( |
| ) |
const |
|
inlinevirtual |
Get the host associated with this connection.
- Returns
- The host of the upstream (even-sending) component
◆ getPort()
virtual int com::apama::engine::EngineConnection::getPort |
( |
| ) |
const |
|
inlinevirtual |
Get the port associated with this connection.
- Returns
- The port of the upstream (even-sending) component
◆ operator<< [1/2]
std::ostream& operator<< |
( |
std::ostream & |
stream, |
|
|
const EngineConnection & |
obj |
|
) |
| |
|
friend |
Stream output operator for a reference.
◆ operator<< [2/2]
std::ostream& operator<< |
( |
std::ostream & |
stream, |
|
|
const EngineConnection * |
obj |
|
) |
| |
|
friend |
Stream output operator for a pointer.
The documentation for this class was generated from the following file: