


Public Member Functions | |
| TestConnect (int args, char *argv[], string &qos1, string &qos2) | |
| Constructs the TestLogin object. | |
| ~TestConnect () | |
| string | update (string &, UpdateKey &, unsigned char *, long, UpdateQos &) |
| This is the callback method (I_Callback) invoked from CorbaConnection informing the client in an asynchronous mode about a new message. | |
| void | setUp () |
| Sets up the fixture. | |
| void | testPubSub () |
| void | tearDown () |
| Tears down the fixture. | |
Definition at line 39 of file TestConnect.cpp.
| org::xmlBlaster::test::TestConnect::TestConnect | ( | int | args, | |
| char * | argv[], | |||
| string & | qos1, | |||
| string & | qos2 | |||
| ) |
Constructs the TestLogin object.
| testName | The name used in the test suite | |
| loginName | The name to login to the xmlBlaster | |
| secondName | The name to login to the xmlBlaster again |
Definition at line 62 of file TestConnect.cpp.
| org::xmlBlaster::test::TestConnect::~TestConnect | ( | ) |
Definition at line 77 of file TestConnect.cpp.
| string org::xmlBlaster::test::TestConnect::update | ( | string & | , | |
| UpdateKey & | , | |||
| unsigned char * | , | |||
| long | , | |||
| UpdateQos & | ||||
| ) |
This is the callback method (I_Callback) invoked from CorbaConnection informing the client in an asynchronous mode about a new message.
The raw CORBA-BlasterCallback.update() is unpacked and for each arrived message this update is called.
| sessionId | The sessionId to authenticate the callback This sessionId was passed on subscription we can use it to decide if we trust this update() | |
| updateKey | The arrived key | |
| content | The arrived message content | |
| qos | Quality of Service of the MessageUnit |
Definition at line 101 of file TestConnect.cpp.
References org::xmlBlaster::util::I_Log::call(), org::xmlBlaster::test::TestSuite::log_, and org::xmlBlaster::test::TestSuite::ME.
| void org::xmlBlaster::test::TestConnect::setUp | ( | ) | [virtual] |
Sets up the fixture.
Connect to xmlBlaster and login
Reimplemented from org::xmlBlaster::test::TestSuite.
Definition at line 117 of file TestConnect.cpp.
References org::xmlBlaster::client::XmlBlasterAccess::connect(), org::xmlBlaster::test::TestSuite::connection_, org::xmlBlaster::client::XmlBlasterAccess::disconnect(), org::xmlBlaster::util::I_Log::error(), org::xmlBlaster::test::TestSuite::global_, org::xmlBlaster::test::TestSuite::log_, org::xmlBlaster::test::TestSuite::ME, org::xmlBlaster::util::qos::ConnectQosFactory::readObject(), org::xmlBlaster::test::TestSuite::setUp(), org::xmlBlaster::util::XmlBlasterException::toXml(), and org::xmlBlaster::test::TestSuite::usage().
Referenced by main().
| void org::xmlBlaster::test::TestConnect::testPubSub | ( | ) |
Definition at line 144 of file TestConnect.cpp.
References org::xmlBlaster::test::assertEquals(), org::xmlBlaster::test::TestSuite::connection_, org::xmlBlaster::client::XmlBlasterAccess::erase(), org::xmlBlaster::util::I_Log::error(), org::xmlBlaster::client::qos::SubscribeReturnQos::getSubscriptionId(), org::xmlBlaster::test::TestSuite::global_, org::xmlBlaster::util::I_Log::info(), org::xmlBlaster::test::TestSuite::log_, org::xmlBlaster::test::TestSuite::ME, org::xmlBlaster::client::XmlBlasterAccess::publish(), org::xmlBlaster::client::key::UnSubscribeKey::setOid(), org::xmlBlaster::client::key::PublishKey::setOid(), org::xmlBlaster::util::thread::Thread::sleepSecs(), org::xmlBlaster::client::XmlBlasterAccess::subscribe(), org::xmlBlaster::util::XmlBlasterException::toXml(), and org::xmlBlaster::test::TestSuite::usage().
Referenced by main().
| void org::xmlBlaster::test::TestConnect::tearDown | ( | ) | [virtual] |
Tears down the fixture.
cleaning up .... erase() the previous message OID and logout
Reimplemented from org::xmlBlaster::test::TestSuite.
Definition at line 186 of file TestConnect.cpp.
References org::xmlBlaster::test::TestSuite::connection_, org::xmlBlaster::client::XmlBlasterAccess::disconnect(), org::xmlBlaster::test::TestSuite::global_, and org::xmlBlaster::test::TestSuite::tearDown().
Referenced by main().