File Information
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, preflightRequest, receive, receiveImpl, removeSubscriber, removeSubscriberImpl, runMain, runWorker, send, sendImpl, shutdown, shutdownImpl, subjectNotified, subscribe, subscribeImpl, subscriberCount, type, unsubscribe, unsubscribeImpl, unwatchSocketImpl, watchSocketImpl
Inherited Functions: duplicate, isA, notify, referenceCount, release, subjectNotified, subscriberCount, type
Types Aliases
Ptr
using Ptr = Poco::AutoPtr < WebEventServiceImpl >;
Constructors
WebEventServiceImpl
WebEventServiceImpl(
Poco::OSP::BundleContext::Ptr pContext,
int maxSockets,
int workerCount
);
Creates the WebEventServiceImpl.
Destructor
~WebEventServiceImpl
Destroys the WebEventServiceImpl.
Member Functions
isA
bool isA(
const std::type_info & otherType
) const;
notify
void notify(
const std::string & subjectName,
const std::string & data
);
subjectNotified
Poco::BasicEvent < const NotificationEvent > & subjectNotified(
const std::string & subject
);
subscriberCount
int subscriberCount(
const std::string & subject
);
type
const std::type_info & type() const;
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
);
preflightRequest
void preflightRequest(
Poco::Net::HTTPServerRequest & request
);
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
);