You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2007/02/11 23:24:51 UTC
svn commit: r506156 -
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Author: tabish
Date: Sun Feb 11 14:24:50 2007
New Revision: 506156
URL: http://svn.apache.org/viewvc?view=rev&rev=506156
Log:
http://issues.apache.org/activemq/browse/AMQCPP-30
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp?view=diff&rev=506156&r1=506155&r2=506156
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp Sun Feb 11 14:24:50 2007
@@ -272,7 +272,7 @@
////////////////////////////////////////////////////////////////////////////////
ConsumerInfo* OpenWireConnector::createConsumer(
const cms::Destination* destination,
- SessionInfo* session,
+ connector::SessionInfo* session,
const std::string& selector,
bool noLocal )
throw ( ConnectorException )
@@ -291,7 +291,7 @@
////////////////////////////////////////////////////////////////////////////////
ConsumerInfo* OpenWireConnector::createDurableConsumer(
const cms::Topic* topic,
- SessionInfo* session,
+ connector::SessionInfo* session,
const std::string& name,
const std::string& selector,
bool noLocal )
@@ -311,7 +311,7 @@
////////////////////////////////////////////////////////////////////////////////
ProducerInfo* OpenWireConnector::createProducer(
const cms::Destination* destination,
- SessionInfo* session )
+ connector::SessionInfo* session )
throw ( ConnectorException )
{
try
@@ -327,7 +327,7 @@
////////////////////////////////////////////////////////////////////////////////
cms::Topic* OpenWireConnector::createTopic( const std::string& name,
- SessionInfo* session )
+ connector::SessionInfo* session )
throw ( ConnectorException )
{
try
@@ -343,7 +343,7 @@
////////////////////////////////////////////////////////////////////////////////
cms::Queue* OpenWireConnector::createQueue( const std::string& name,
- SessionInfo* session )
+ connector::SessionInfo* session )
throw ( ConnectorException )
{
try
@@ -359,7 +359,7 @@
////////////////////////////////////////////////////////////////////////////////
cms::TemporaryTopic* OpenWireConnector::createTemporaryTopic(
- SessionInfo* session )
+ connector::SessionInfo* session )
throw ( ConnectorException )
{
try
@@ -375,7 +375,7 @@
////////////////////////////////////////////////////////////////////////////////
cms::TemporaryQueue* OpenWireConnector::createTemporaryQueue(
- SessionInfo* session )
+ connector::SessionInfo* session )
throw ( ConnectorException )
{
try
@@ -462,7 +462,7 @@
}
////////////////////////////////////////////////////////////////////////////////
-void OpenWireConnector::acknowledge( const SessionInfo* session,
+void OpenWireConnector::acknowledge( const connector::SessionInfo* session,
const cms::Message* message,
AckType ackType = ConsumedAck )
throw ( ConnectorException )
@@ -507,7 +507,7 @@
////////////////////////////////////////////////////////////////////////////////
TransactionInfo* OpenWireConnector::startTransaction(
- SessionInfo* session )
+ connector::SessionInfo* session )
throw ( ConnectorException )
{
try {
@@ -543,7 +543,7 @@
////////////////////////////////////////////////////////////////////////////////
void OpenWireConnector::commit( TransactionInfo* transaction,
- SessionInfo* session )
+ connector::SessionInfo* session )
throw ( ConnectorException )
{
try
@@ -568,7 +568,7 @@
////////////////////////////////////////////////////////////////////////////////
void OpenWireConnector::rollback( TransactionInfo* transaction,
- SessionInfo* session )
+ connector::SessionInfo* session )
throw ( ConnectorException )
{
try
@@ -593,7 +593,7 @@
////////////////////////////////////////////////////////////////////////////////
cms::Message* OpenWireConnector::createMessage(
- SessionInfo* session,
+ connector::SessionInfo* session,
TransactionInfo* transaction )
throw ( ConnectorException )
{
@@ -611,7 +611,7 @@
////////////////////////////////////////////////////////////////////////////////
cms::BytesMessage* OpenWireConnector::createBytesMessage(
- SessionInfo* session,
+ connector::SessionInfo* session,
TransactionInfo* transaction )
throw ( ConnectorException )
{
@@ -629,7 +629,7 @@
////////////////////////////////////////////////////////////////////////////////
cms::TextMessage* OpenWireConnector::createTextMessage(
- SessionInfo* session,
+ connector::SessionInfo* session,
TransactionInfo* transaction )
throw ( ConnectorException )
{
@@ -647,7 +647,7 @@
////////////////////////////////////////////////////////////////////////////////
cms::MapMessage* OpenWireConnector::createMapMessage(
- SessionInfo* session,
+ connector::SessionInfo* session,
TransactionInfo* transaction )
throw ( ConnectorException )
{
@@ -680,10 +680,10 @@
{
try
{
- ConsumerInfo* consumer =
- dynamic_cast<ConsumerInfo*>(resource);
- SessionInfo* session =
- dynamic_cast<SessionInfo*>(resource);
+ connector::ConsumerInfo* consumer =
+ dynamic_cast<connector::ConsumerInfo*>(resource);
+ connector::SessionInfo* session =
+ dynamic_cast<connector::SessionInfo*>(resource);
// TODO