org::xmlBlaster::client::protocol::corba::CorbaDriver

org::xmlBlaster::client::protocol::corba::CorbaDriver Class Reference

Inheritance diagram for org::xmlBlaster::client::protocol::corba::CorbaDriver:

Inheritance graph
[legend]
Collaboration diagram for org::xmlBlaster::client::protocol::corba::CorbaDriver:

Collaboration graph
[legend]
List of all members.

Public Member Functions

bool orbIsThreadSafe ()
 For single threaded CORBA implementations only (like MICO).
void initialize (std::string &name, org::xmlBlaster::client::I_Callback &client)
 Initialize and start the callback server.
std::string getCbProtocol ()
 Returns the 'well known' protocol type.
std::string getCbAddress ()
 Returns the current callback address.
bool shutdownCb ()
 Stop the server.
org::xmlBlaster::util::qos::ConnectReturnQosRef connect (org::xmlBlaster::util::qos::ConnectQosRef &qos)
 connect() is a login or authentication as well, the authentication schema is transported in the qos.
bool disconnect (org::xmlBlaster::util::qos::DisconnectQos &qos)
 Logout from xmlBlaster.
std::string getProtocol ()
 
Returns:
The connection protocol name "IOR" or "SOCKET" etc.

bool shutdown ()
 Is called when we disconnect or automatically when are going to POLLING mode.
std::string getLoginName ()
bool isLoggedIn ()
std::string ping (std::string &qos)
org::xmlBlaster::client::qos::SubscribeReturnQos subscribe (org::xmlBlaster::client::key::SubscribeKey &key, org::xmlBlaster::client::qos::SubscribeQos &qos)
std::vector< org::xmlBlaster::util::MessageUnit > get (org::xmlBlaster::client::key::GetKey &key, org::xmlBlaster::client::qos::GetQos &qos)
std::vector< org::xmlBlaster::client::qos::UnSubscribeReturnQos > unSubscribe (org::xmlBlaster::client::key::UnSubscribeKey &key, org::xmlBlaster::client::qos::UnSubscribeQos &qos)
org::xmlBlaster::client::qos::PublishReturnQos publish (org::xmlBlaster::util::MessageUnit &msgUnit)
void publishOneway (std::vector< org::xmlBlaster::util::MessageUnit > &msgUnitArr)
std::vector< org::xmlBlaster::client::qos::PublishReturnQos > publishArr (std::vector< org::xmlBlaster::util::MessageUnit > &msgUnitArr)
std::vector< org::xmlBlaster::client::qos::EraseReturnQos > erase (org::xmlBlaster::client::key::EraseKey &key, org::xmlBlaster::client::qos::EraseQos &qos)
org::xmlBlaster::client::protocol::I_ProgressListener * registerProgressListener (org::xmlBlaster::client::protocol::I_ProgressListener *listener)
 
See also:
org::xmlBlaster::client::protocol::I_CallbackServer::registerProgressListener

std::string getType ()
 Get the name of the plugin.
std::string getVersion ()
 Get the version of the plugin.

Static Public Member Functions

static std::string usage ()
static org::xmlBlaster::util::XmlBlasterException convertFromCorbaException (serverIdl::XmlBlasterException &ex)
static serverIdl::XmlBlasterException convertToCorbaException (org::xmlBlaster::util::XmlBlasterException &ex)

Friends

class CorbaDriverFactory

Detailed Description

Definition at line 34 of file CorbaDriver.h.

Member Function Documentation

bool org::xmlBlaster::client::protocol::corba::CorbaDriver::orbIsThreadSafe (  ) 

For single threaded CORBA implementations only (like MICO).

One instance (the first) starts a main loop and checks if the orb has some work to perform (every 20 millis). In your real application this should be done by your main loop (e.g. from X-Window) E.g. mico has a helper implementation to register its file descriptors with another main loop.

Definition at line 87 of file CorbaDriver.h.

void org::xmlBlaster::client::protocol::corba::CorbaDriver::initialize ( std::string &  name,
org::xmlBlaster::client::I_Callback &  client 
) [virtual]

Initialize and start the callback server.

This is guaranteed to be invoked after the default constructor.

Parameters:
glob The global handle with your environment settings
name The login name of the client, for logging only
client Your implementation to receive the callback messages from xmlBlaster

Implements org::xmlBlaster::client::protocol::I_CallbackServer.

string org::xmlBlaster::client::protocol::corba::CorbaDriver::getCbProtocol (  )  [virtual]

Returns the 'well known' protocol type.

Returns:
E.g. "RMI", "SOCKET", "XMLRPC"

Implements org::xmlBlaster::client::protocol::I_CallbackServer.

Definition at line 224 of file CorbaDriver.cpp.

References org::xmlBlaster::util::Constants::IOR.

string org::xmlBlaster::client::protocol::corba::CorbaDriver::getCbAddress (  )  [virtual]

Returns the current callback address.

Returns:
"rmi://develop.MarcelRuff.info:1099/xmlBlasterCB", "127.128.2.1:7607", "http://XMLRPC" or null if not known

Implements org::xmlBlaster::client::protocol::I_CallbackServer.

Definition at line 229 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, and org::xmlBlaster::client::protocol::corba::CorbaConnection::getCbAddress().

bool org::xmlBlaster::client::protocol::corba::CorbaDriver::shutdownCb (  )  [virtual]

Stop the server.

Returns:
true if everything went fine.

Implements org::xmlBlaster::client::protocol::I_CallbackServer.

Definition at line 236 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, and org::xmlBlaster::client::protocol::corba::CorbaConnection::shutdownCb().

ConnectReturnQosRef org::xmlBlaster::client::protocol::corba::CorbaDriver::connect ( org::xmlBlaster::util::qos::ConnectQosRef &  qos  )  [virtual]

connect() is a login or authentication as well, the authentication schema is transported in the qos.

Parameters:
qos The authentication and other informations
client A handle to your callback if desired or null
Returns:
org::xmlBlaster::util::qos::ConnectReturnQos

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 243 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, and org::xmlBlaster::client::protocol::corba::CorbaConnection::connect().

bool org::xmlBlaster::client::protocol::corba::CorbaDriver::disconnect ( org::xmlBlaster::util::qos::DisconnectQos &  qos  )  [virtual]

Logout from xmlBlaster.

Parameters:
qos The QoS or null

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 251 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, org::xmlBlaster::client::protocol::corba::CorbaConnection::disconnect(), and org::xmlBlaster::util::qos::DisconnectQos::toXml().

string org::xmlBlaster::client::protocol::corba::CorbaDriver::getProtocol (  )  [virtual]

Returns:
The connection protocol name "IOR" or "SOCKET" etc.

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 259 of file CorbaDriver.cpp.

References org::xmlBlaster::util::Constants::IOR.

bool org::xmlBlaster::client::protocol::corba::CorbaDriver::shutdown (  )  [virtual]

Is called when we disconnect or automatically when are going to POLLING mode.

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 274 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, and org::xmlBlaster::client::protocol::corba::CorbaConnection::shutdown().

string org::xmlBlaster::client::protocol::corba::CorbaDriver::getLoginName (  )  [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 282 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, and org::xmlBlaster::client::protocol::corba::CorbaConnection::getLoginName().

bool org::xmlBlaster::client::protocol::corba::CorbaDriver::isLoggedIn (  )  [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 289 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, and org::xmlBlaster::client::protocol::corba::CorbaConnection::isLoggedIn().

std::string org::xmlBlaster::client::protocol::corba::CorbaDriver::ping ( std::string &  qos  )  [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

SubscribeReturnQos org::xmlBlaster::client::protocol::corba::CorbaDriver::subscribe ( org::xmlBlaster::client::key::SubscribeKey &  key,
org::xmlBlaster::client::qos::SubscribeQos &  qos 
) [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 304 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, org::xmlBlaster::util::qos::StatusQosFactory::readObject(), org::xmlBlaster::client::protocol::corba::CorbaConnection::subscribe(), org::xmlBlaster::client::qos::UnSubscribeQos::toXml(), and org::xmlBlaster::client::key::UnSubscribeKey::toXml().

vector< MessageUnit > org::xmlBlaster::client::protocol::corba::CorbaDriver::get ( org::xmlBlaster::client::key::GetKey &  key,
org::xmlBlaster::client::qos::GetQos &  qos 
) [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 313 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, org::xmlBlaster::client::protocol::corba::CorbaConnection::get(), org::xmlBlaster::client::qos::UnSubscribeQos::toXml(), and org::xmlBlaster::client::key::UnSubscribeKey::toXml().

vector< UnSubscribeReturnQos > org::xmlBlaster::client::protocol::corba::CorbaDriver::unSubscribe ( org::xmlBlaster::client::key::UnSubscribeKey &  key,
org::xmlBlaster::client::qos::UnSubscribeQos &  qos 
) [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 322 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, org::xmlBlaster::util::qos::StatusQosFactory::readObject(), org::xmlBlaster::client::qos::UnSubscribeQos::toXml(), org::xmlBlaster::client::key::UnSubscribeKey::toXml(), and org::xmlBlaster::client::protocol::corba::CorbaConnection::unSubscribe().

PublishReturnQos org::xmlBlaster::client::protocol::corba::CorbaDriver::publish ( org::xmlBlaster::util::MessageUnit &  msgUnit  )  [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 337 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, org::xmlBlaster::util::I_Log::call(), org::xmlBlaster::client::protocol::corba::CorbaConnection::publish(), org::xmlBlaster::util::qos::StatusQosFactory::readObject(), and org::xmlBlaster::util::I_Log::trace().

void org::xmlBlaster::client::protocol::corba::CorbaDriver::publishOneway ( std::vector< org::xmlBlaster::util::MessageUnit > &  msgUnitArr  )  [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

std::vector<org::xmlBlaster::client::qos::PublishReturnQos> org::xmlBlaster::client::protocol::corba::CorbaDriver::publishArr ( std::vector< org::xmlBlaster::util::MessageUnit > &  msgUnitArr  )  [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

vector< EraseReturnQos > org::xmlBlaster::client::protocol::corba::CorbaDriver::erase ( org::xmlBlaster::client::key::EraseKey &  key,
org::xmlBlaster::client::qos::EraseQos &  qos 
) [virtual]

Implements org::xmlBlaster::client::protocol::I_XmlBlasterConnection.

Definition at line 371 of file CorbaDriver.cpp.

References _COMM_CATCH, _COMM_TRY, org::xmlBlaster::client::protocol::corba::CorbaConnection::erase(), org::xmlBlaster::util::qos::StatusQosFactory::readObject(), org::xmlBlaster::client::qos::UnSubscribeQos::toXml(), and org::xmlBlaster::client::key::UnSubscribeKey::toXml().

I_ProgressListener * org::xmlBlaster::client::protocol::corba::CorbaDriver::registerProgressListener ( org::xmlBlaster::client::protocol::I_ProgressListener *  listener  )  [virtual]

See also:
org::xmlBlaster::client::protocol::I_CallbackServer::registerProgressListener

Implements org::xmlBlaster::client::protocol::I_CallbackServer.

Definition at line 386 of file CorbaDriver.cpp.

References org::xmlBlaster::util::I_Log::warn().

std::string org::xmlBlaster::client::protocol::corba::CorbaDriver::usage (  )  [static]

Definition at line 391 of file CorbaDriver.cpp.

References org::xmlBlaster::client::protocol::corba::CorbaConnection::usage().

Referenced by org::xmlBlaster::util::Global::usage().

org::xmlBlaster::util::XmlBlasterException org::xmlBlaster::client::protocol::corba::CorbaDriver::convertFromCorbaException ( serverIdl::XmlBlasterException &  ex  )  [static]

Definition at line 399 of file CorbaDriver.cpp.

References serverIdl::XmlBlasterException::embeddedMessage, serverIdl::XmlBlasterException::errorCodeStr, serverIdl::XmlBlasterException::lang, serverIdl::XmlBlasterException::location, serverIdl::XmlBlasterException::message, serverIdl::XmlBlasterException::node, serverIdl::XmlBlasterException::stackTrace, serverIdl::XmlBlasterException::timestampStr, serverIdl::XmlBlasterException::transactionInfo, and serverIdl::XmlBlasterException::versionInfo.

Referenced by org::xmlBlaster::client::protocol::corba::CorbaConnection::initAuthenticationService().

serverIdl::XmlBlasterException org::xmlBlaster::client::protocol::corba::CorbaDriver::convertToCorbaException ( org::xmlBlaster::util::XmlBlasterException &  ex  )  [static]

Definition at line 415 of file CorbaDriver.cpp.

References org::xmlBlaster::util::XmlBlasterException::getEmbeddedMessage(), org::xmlBlaster::util::XmlBlasterException::getErrorCodeStr(), org::xmlBlaster::util::XmlBlasterException::getLang(), org::xmlBlaster::util::XmlBlasterException::getLocation(), org::xmlBlaster::util::XmlBlasterException::getMessage(), org::xmlBlaster::util::XmlBlasterException::getNode(), org::xmlBlaster::util::XmlBlasterException::getStackTraceStr(), org::xmlBlaster::util::XmlBlasterException::getTimestamp(), org::xmlBlaster::util::XmlBlasterException::getTransactionInfo(), and org::xmlBlaster::util::XmlBlasterException::getVersionInfo().

std::string org::xmlBlaster::client::protocol::corba::CorbaDriver::getType (  )  [virtual]

Get the name of the plugin.

Returns:
"IOR" I_Plugin

Implements org::xmlBlaster::util::plugin::I_Plugin.

Definition at line 141 of file CorbaDriver.h.

References org::xmlBlaster::util::Constants::IOR.

std::string org::xmlBlaster::client::protocol::corba::CorbaDriver::getVersion (  )  [virtual]

Get the version of the plugin.

Returns:
"1.0" I_Plugin

Implements org::xmlBlaster::util::plugin::I_Plugin.

Definition at line 148 of file CorbaDriver.h.

Friends And Related Function Documentation

friend class CorbaDriverFactory [friend]

Definition at line 39 of file CorbaDriver.h.

The documentation for this class was generated from the following files: