Class Poco::RemotingNG::TCP::Transport

Library: RemotingNG/TCP
Package: TCP
Header: Poco/RemotingNG/TCP/Transport.h

Description

The Transport implementation for RemotingNG TCP.

Inheritance

Direct Base Classes: Poco::RemotingNG::Transport

All Base Classes: Poco::RefCountedObject, Poco::RemotingNG::AttributedObject, Poco::RemotingNG::Transport

Member Summary

Member Functions: beginMessage, beginRequest, connect, connected, disconnect, enableCompression, endPoint, endRequest, getTimeout, isCompressionEnabled, sendMessage, sendRequest, setTimeout, setupSerializer

Inherited Functions: beginMessage, beginRequest, connect, connected, disconnect, duplicate, endPoint, endRequest, getAttribute, hasAttribute, lock, referenceCount, release, sendMessage, sendRequest, setAttribute, unlock

Constructors

Transport

explicit Transport(
ConnectionManager & connectionManager
);

Creates a Transport using the given ConnectionManager.

Destructor

~Transport

~Transport();

Destroys the Transport.

Member Functions

beginMessage

Poco::RemotingNG::Serializer & beginMessage(
    const Poco::RemotingNG::Identifiable::ObjectId & oid,
    const Poco::RemotingNG::Identifiable::TypeId & tid,
    const std::string & messageName,
    Poco::RemotingNG::SerializerBase::MessageType messageType
);

beginRequest

Poco::RemotingNG::Serializer & beginRequest(
    const Poco::RemotingNG::Identifiable::ObjectId & oid,
    const Poco::RemotingNG::Identifiable::TypeId & tid,
    const std::string & messageName,
    Poco::RemotingNG::SerializerBase::MessageType messageType
);

connect

void connect(
const std::string & endPoint
);

connected

bool connected() const;

disconnect

void disconnect();

enableCompression

void enableCompression(
bool enable
);

Enables or disables zlib deflate compression for requests.

endPoint

const std::string & endPoint() const;

endRequest

void endRequest();

getTimeout

Poco::Timespan getTimeout() const;

Returns the response timeout.

isCompressionEnabled

bool isCompressionEnabled() const;

Returns true if and only if zlib deflate compression is enabled for requests. Default is disabled.

sendMessage

void sendMessage(
    const Poco::RemotingNG::Identifiable::ObjectId & oid,
    const Poco::RemotingNG::Identifiable::TypeId & tid,
    const std::string & messageName,
    Poco::RemotingNG::SerializerBase::MessageType messageType
);

sendRequest

Poco::RemotingNG::Deserializer & sendRequest(
    const Poco::RemotingNG::Identifiable::ObjectId & oid,
    const Poco::RemotingNG::Identifiable::TypeId & tid,
    const std::string & messageName,
    Poco::RemotingNG::SerializerBase::MessageType messageType
);

setTimeout

void setTimeout(
const Poco::Timespan & timeout
);

Sets the response timeout.

setupSerializer

void setupSerializer(
    const Poco::RemotingNG::Identifiable::ObjectId & oid,
    const Poco::RemotingNG::Identifiable::TypeId & tid,
    Poco::RemotingNG::SerializerBase::MessageType messageType,
    Poco::UInt16 frameFlags
);

Variables

PROTOCOL

static const std::string PROTOCOL;