Public Member Functions | |
| PublishDemo (Global &glob) | |
| void | run () |
| void | initEnvironment () |
| void | connect () |
| void | publish () |
| void | erase () |
| void | postSend (org::xmlBlaster::util::queue::MsgQueueEntry &msgQueueEntry) |
| Is called after each successful send tail back message from client side queue (typically after a connection loss with ongoing publishes). | |
Definition at line 55 of file PublishDemo.cpp.
| PublishDemo::PublishDemo | ( | Global & | glob | ) |
| void PublishDemo::run | ( | ) |
Definition at line 102 of file PublishDemo.cpp.
References connect(), org::xmlBlaster::client::XmlBlasterAccess::disconnect(), erase(), and publish().
Referenced by PublishDemo().
| void PublishDemo::initEnvironment | ( | ) |
Definition at line 152 of file PublishDemo.cpp.
References org::xmlBlaster::util::Property::get(), org::xmlBlaster::util::Global::getProperty(), org::xmlBlaster::util::I_Log::info(), org::xmlBlaster::util::int2Priority(), org::xmlBlaster::util::NORM_PRIORITY, and org::xmlBlaster::util::qos::ClientProperty::setCharset().
Referenced by PublishDemo().
| void PublishDemo::connect | ( | ) |
Definition at line 259 of file PublishDemo.cpp.
References org::xmlBlaster::client::XmlBlasterAccess::connect(), org::xmlBlaster::client::XmlBlasterAccess::getServerNodeId(), org::xmlBlaster::client::XmlBlasterAccess::registerPostSendListener(), org::xmlBlaster::util::qos::ConnectQosData::toXml(), and org::xmlBlaster::util::I_Log::trace().
Referenced by run().
| void PublishDemo::publish | ( | ) |
Definition at line 272 of file PublishDemo.cpp.
References org::xmlBlaster::client::qos::PublishQos::addClientProperty(), org::xmlBlaster::client::qos::PublishQos::addDestination(), org::xmlBlaster::util::I_Log::error(), org::xmlBlaster::util::Destination::forceQueuing(), org::xmlBlaster::util::I_Log::info(), org::xmlBlaster::client::XmlBlasterAccess::publish(), org::xmlBlaster::client::XmlBlasterAccess::publishOneway(), org::xmlBlaster::client::qos::PublishQos::setClientProperties(), org::xmlBlaster::client::key::PublishKey::setClientTags(), org::xmlBlaster::util::qos::TopicProperty::setCreateDomEntry(), org::xmlBlaster::util::qos::TopicProperty::setDestroyDelay(), org::xmlBlaster::client::key::PublishKey::setDomain(), org::xmlBlaster::client::qos::PublishQos::setForceDestroy(), org::xmlBlaster::client::qos::PublishQos::setForceUpdate(), org::xmlBlaster::util::qos::TopicProperty::setHistoryQueueProperty(), org::xmlBlaster::client::qos::PublishQos::setLifeTime(), org::xmlBlaster::util::qos::storage::QueuePropertyBase::setMaxEntries(), org::xmlBlaster::client::qos::PublishQos::setPersistent(), org::xmlBlaster::client::qos::PublishQos::setPriority(), org::xmlBlaster::util::qos::TopicProperty::setReadonly(), org::xmlBlaster::client::qos::PublishQos::setSubscribable(), org::xmlBlaster::client::qos::PublishQos::setTopicProperty(), org::xmlBlaster::util::thread::Thread::sleep(), org::xmlBlaster::client::qos::PublishReturnQos::toXml(), org::xmlBlaster::util::MessageUnit::toXml(), org::xmlBlaster::client::qos::PublishQos::toXml(), org::xmlBlaster::util::qos::TopicProperty::toXml(), org::xmlBlaster::client::key::MsgKeyBase::toXml(), org::xmlBlaster::util::XmlBlasterException::toXml(), and org::xmlBlaster::util::I_Log::trace().
Referenced by run().
| void PublishDemo::erase | ( | ) |
Definition at line 116 of file PublishDemo.cpp.
References org::xmlBlaster::client::XmlBlasterAccess::erase(), org::xmlBlaster::util::I_Log::info(), org::xmlBlaster::client::qos::EraseQos::setForceDestroy(), org::xmlBlaster::client::key::UnSubscribeKey::setOid(), and org::xmlBlaster::util::waitOnKeyboardHit().
Referenced by run().
| void PublishDemo::postSend | ( | org::xmlBlaster::util::queue::MsgQueueEntry & | msgQueueEntry | ) | [virtual] |
Is called after each successful send tail back message from client side queue (typically after a connection loss with ongoing publishes).
Implements org::xmlBlaster::util::dispatch::I_PostSendListener.
Definition at line 138 of file PublishDemo.cpp.
References org::xmlBlaster::client::qos::PublishReturnQos::getState(), org::xmlBlaster::util::I_Log::info(), and org::xmlBlaster::util::queue::MsgQueueEntry::isPublish().