Class Poco::OSP::WebEvent::WebEventServiceImpl

Library: OSP/WebEvent
Package: WebEvent
Header: Poco/OSP/WebEvent/WebEventServiceImpl.h

Inheritance

Direct Base Classes: WebEventService

All Base Classes: Poco::OSP::Service, WebEventService, Poco::RefCountedObject

Member Summary

Member Functions: addSubscriber, addSubscriberImpl, isA, notify, notifyImpl, receive, receiveImpl, removeSubscriber, removeSubscriberImpl, runMain, runWorker, send, sendImpl, shutdown, shutdownImpl, subscribe, subscribeImpl, type, unsubscribe, unsubscribeImpl, unwatchSocketImpl, watchSocketImpl

Inherited Functions: duplicate, isA, notify, referenceCount, release, type

Types

Ptr

typedef Poco::AutoPtr < WebEventServiceImpl > Ptr;

Constructors

WebEventServiceImpl

WebEventServiceImpl(
Poco::OSP::BundleContext::Ptr pContext
);

Creates the WebEventServiceImpl.

Destructor

~WebEventServiceImpl

~WebEventServiceImpl();

Destroys the WebEventServiceImpl.

Member Functions

isA

bool isA(
const std::type_info & otherType
) const;

See also: Poco::OSP::WebEvent::WebEventService::isA()

notify

void notify(
const std::string & subjectName,
const std::string & data
);

See also: Poco::OSP::WebEvent::WebEventService::notify()

type

const std::type_info & type() const;

See also: Poco::OSP::WebEvent::WebEventService::type()

addSubscriber

void addSubscriber(
Poco::SharedPtr < Poco::Net::WebSocket > pWS
);

addSubscriberImpl

void addSubscriberImpl(
Poco::SharedPtr < Poco::Net::WebSocket > pWS
);

notifyImpl

void notifyImpl(
const std::string & subjectName,
const std::string & data
);

receive

void receive(
Poco::SharedPtr < Poco::Net::WebSocket > pWS
);

receiveImpl

void receiveImpl(
Poco::SharedPtr < Poco::Net::WebSocket > pWS
);

removeSubscriber

void removeSubscriber(
Poco::SharedPtr < Poco::Net::WebSocket > pWS,
bool clientShutdown
);

removeSubscriberImpl

void removeSubscriberImpl(
Poco::SharedPtr < Poco::Net::WebSocket > pWS,
bool clientShutdown
);

runMain

void runMain();

runWorker

void runWorker();

send

void send(
Poco::SharedPtr < Poco::Net::WebSocket > pWS,
const std::string & message
);

sendImpl

void sendImpl(
Poco::SharedPtr < Poco::Net::WebSocket > pWS,
const std::string & message
);

shutdown

void shutdown(
    Poco::SharedPtr < Poco::Net::WebSocket > pWS,
    Poco::UInt16 statusCode,
    const std::string & statusMessage,
    bool passive
);

shutdownImpl

void shutdownImpl(
    Poco::SharedPtr < Poco::Net::WebSocket > pWS,
    Poco::UInt16 statusCode,
    const std::string & statusMessage,
    bool passive
);

subscribe

void subscribe(
Poco::SharedPtr < Poco::Net::WebSocket > pWS,
const std::set < std::string > & subjectNames
);

subscribeImpl

void subscribeImpl(
Poco::SharedPtr < Poco::Net::WebSocket > pWS,
const std::set < std::string > & subjectNames
);

unsubscribe

void unsubscribe(
Poco::SharedPtr < Poco::Net::WebSocket > pWS,
const std::set < std::string > & subjectNames
);

unsubscribeImpl

void unsubscribeImpl(
Poco::SharedPtr < Poco::Net::WebSocket > pWS,
const std::set < std::string > & subjectNames
);

unwatchSocketImpl

void unwatchSocketImpl(
const Poco::Net::Socket & socket
);

watchSocketImpl

void watchSocketImpl(
const Poco::Net::Socket & socket
);