magickangaroo / pyactivemq Goto Github PK

Complete the test of durable subscription.

What steps will reproduce the problem?
1. Build ActiveMQ-CPP v3.1.3 and install
2. Build the pyActiveMQ against the 3.1.3 installation
3. Run the tests

What is the expected output? What do you see instead?

The tests should pass, they don't


What version of the product are you using? On what operating system?

using trunk version of pyActiveMQ and v3.1.3 of ActiveMQ-CPP

Please provide any additional information below.

Patch supplied to fix the tests to work with the v3.1.3 API

What steps will reproduce the problem?
1. Download the latest ActiveMQ C++ trunk or the 2.1.3 release
2. Build and install the activemq-cpp
3. Download the pyactivemq trunk
4. Build the package with pyhon setup.build

What is the expected output? What do you see instead?

Getting this output/error:
$ python setup.py build
running build
running build_ext
building 'pyactivemq' extension
creating build
creating build/temp.macosx-10.3-i386-2.5
creating build/temp.macosx-10.3-i386-2.5/src
creating build/temp.macosx-10.3-i386-2.5/src/main
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/ActiveMQConnectionFactory.cpp -o build/temp.macosx-10.3-i386-
2.5/src/main/ActiveMQConnectionFactory.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/BytesMessage.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/BytesMessage.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/CMSException.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/CMSException.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/Connection.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/Connection.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/ConnectionFactory.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/ConnectionFactory.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/Destinations.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/Destinations.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/ExceptionListener.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/ExceptionListener.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/MapMessage.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/MapMessage.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/Message.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/Message.o
gcc -arch ppc -arch i386 -isysroot /Developer/SDKs/MacOSX10.4u.sdk 
-fno-strict-aliasing -
DSTACKLESS_FRHACK=1 -Wno-long-double -no-cpp-precomp -mno-fused-madd 
-fno-common -
dynamic -DNDEBUG -g -O3 -I../activemq-cpp/src/main -
I/Library/Frameworks/Python.framework/Versions/2.5/include/python2.5 -c 
src/main/MessageConsumer.cpp -o 
build/temp.macosx-10.3-i386-2.5/src/main/MessageConsumer.o
../activemq-cpp/src/main/boost/python/detail/caller.hpp: In static member 
function ‘static const 
PyTypeObject* 
boost::python::detail::converter_target_type<ResultConverter>::get_pytype() 
[with 
ResultConverter = to_python_Message<cms::Message*>]’:
../activemq-cpp/src/main/boost/python/detail/caller.hpp:242:   instantiated 
from ‘static 
boost::python::detail::py_func_sig_info 
boost::python::detail::caller_arity<1u>::impl<F, Policies, 
Sig>::signature() [with F = cms::Message* (cms::MessageConsumer::*)(), Policies 
= 
boost::python::return_value_policy<manage_new_Message, 
boost::python::default_call_policies>, Sig = 
boost::mpl::vector2<cms::Message*, cms::MessageConsumer&>]’
../activemq-cpp/src/main/boost/python/object/py_function.hpp:48:   instantiated 
from 
‘boost::python::detail::py_func_sig_info 
boost::python::objects::caller_py_function_impl<Caller>::signature() 
const [with Caller = boost::python::detail::caller<cms::Message* 
(cms::MessageConsumer::*)(), 
boost::python::return_value_policy<manage_new_Message, 
boost::python::default_call_policies>, 
boost::mpl::vector2<cms::Message*, cms::MessageConsumer&> >]’
src/main/MessageConsumer.cpp:85:   instantiated from here
../activemq-cpp/src/main/boost/python/detail/caller.hpp:102: error: ‘struct 
to_python_Message<cms::Message*>’ has no member named ‘get_pytype’
../activemq-cpp/src/main/boost/python/detail/caller.hpp: In static member 
function ‘static const 
PyTypeObject* 
boost::python::detail::converter_target_type<ResultConverter>::get_pytype() 
[with 
ResultConverter = to_python_Message<cms::Message*>]’:
../activemq-cpp/src/main/boost/python/detail/caller.hpp:242:   instantiated 
from ‘static 
boost::python::detail::py_func_sig_info 
boost::python::detail::caller_arity<1u>::impl<F, Policies, 
Sig>::signature() [with F = cms::Message* (cms::MessageConsumer::*)(), Policies 
= 
boost::python::return_value_policy<manage_new_Message, 
boost::python::default_call_policies>, Sig = 
boost::mpl::vector2<cms::Message*, cms::MessageConsumer&>]’
../activemq-cpp/src/main/boost/python/object/py_function.hpp:48:   instantiated 
from 
‘boost::python::detail::py_func_sig_info 
boost::python::objects::caller_py_function_impl<Caller>::signature() 
const [with Caller = boost::python::detail::caller<cms::Message* 
(cms::MessageConsumer::*)(), 
boost::python::return_value_policy<manage_new_Message, 
boost::python::default_call_policies>, 
boost::mpl::vector2<cms::Message*, cms::MessageConsumer&> >]’
src/main/MessageConsumer.cpp:85:   instantiated from here
../activemq-cpp/src/main/boost/python/detail/caller.hpp:102: error: ‘struct 
to_python_Message<cms::Message*>’ has no member named ‘get_pytype’
lipo: can't figure out the architecture type of: 
/var/folders/19/19LcQO4hHs8lWkK6nAZHnU+++TI/-Tmp-
//ccft0Iyd.out
error: command 'gcc' failed with exit status 1


What version of the product are you using? On what operating system?
MacBook Pro OS X 10.5.2
Python 2.5.2 Stackless 3.1b3 060516 (python-2.52:61022, Feb 27 2008, 16:52:03) 
[GCC 4.0.1 (Apple Computer, Inc. build 5341)] on darwin
Type "help", "copyright", "credits" or "license" for more information.

Please provide any additional information below.

I want to use the pyactivemq for python 2.4. I found the pyactivemq-0.1.0 does 
not support.Because the pyactivemq.sln can not open by visual studio 2003.

What steps will reproduce the problem?
1. Compile pyactivemq trunk with GCC 4.1.1.
2. Import pyactivemq.
3.

What is the expected output? What do you see instead?

ImportError: pyactivemq.so: undefined symbol:
_ZN3cms12DeliveryMode10PERSISTENTE

Please use labels and text to provide additional information.

You can reproduce this easily by modifying asynclistener.py to use queues
instead of topics.

Finish the wrapper for BytesMessage::readBytes.

Allow user to pass an argument indicating the maximum number of bytes to read.

From a user:

"""
I'm using the pyactivemq bindings and it seems that it's the best way to 
get interface to ActiveMQ for Python. They work well, except that while a 
consumer is doing 'receive' no system signals are received (CTRL+C doesn't 
work, other signals too). This is important for me because I use signals 
for communication between processes. Do you know if it's a limitation of 
ActiveMQ-CPP? Or something can be done in pyactivemq?
"""

Maybe NumPy can help:

http://projects.scipy.org/pipermail/numpy-discussion/2006-
August/010176.html

Wrap 2-argument Session::createBytesMessage member function.

So people can check that file to see what changed in the codebase (fixes, new 
features, API 
changes). See http://svn.pyamf.org/pyamf/trunk/CHANGES.txt for an obvious 
example.

Allow ExceptionListeners to keep a reference to exception by passing a held
clone of the exception to the listener.

The Global Interpreter Lock might not be released if the MessageListener
throws an exception from Python.

What steps will reproduce the problem?
1. python step.py build

What is the expected output? What do you see instead?
Expected: build successful

src/main/Destinations.cpp: In function ‘void export_Destinations()’:
src/main/Destinations.cpp:95:26: error: ‘toProviderString’ is not a member 
of ‘cms::Destination’
src/main/Destinations.cpp:96:27: error: ‘toProviderString’ is not a member 
of ‘cms::Destination’
src/main/Destinations.cpp:98:42: error: ‘toProviderString’ is not a member 
of ‘cms::Destination’
src/main/Destinations.cpp: At global scope:
src/main/Destinations.cpp:40:20: warning: ‘DestinationType_docstring’ 
defined but not used [-Wunused-variable]
error: command 'gcc' failed with exit status 1

What version of the product are you using? On what operating system?
pyactivemq-0.1.0. Fedora

Request for support for Python 3.1 and ActiveMQ-CPP 3.1.1.

I tried to compile pyactivemq for python 2.5 (windows xp) but it didn't
work. The compilation of apr, apr-util and apr-iconv was successfull, but
when compiling activemq-cpp-library-3.0.1 i had many errors. I tried with
the activemq-cpp-library-3.1.0 without success. Did anyone try to compile
for python 2.5 ???

What steps will reproduce the problem?
1. Install recently released activemq-cpp 3.3.0
2. Check out latest revision svn r209 from svn
3. usr/bin/python setup.py build

What is the expected output? 

expect it to build.

What do you see instead?

+ /usr/bin/python setup.py build
running build
running build_ext
building 'pyactivemq' extension
creating build
creating build/temp.linux-i686-2.7
creating build/temp.linux-i686-2.7/src
creating build/temp.linux-i686-2.7/src/main
gcc -pthread -DNDEBUG -O2 -g -pipe -Wall -Wp,-D_FORTIFY_SOURCE=2 -fexceptions 
-fstack-protector --param=ssp-buffer-size=4 -m32 -march=i686 -mtune=atom 
-fasynchronous-unwind-tables -D_GNU_SOURCE -fPIC -fwrapv -O2 -g -pipe -Wall 
-Wp,-D_FORTIFY_SOURCE=2 -fexceptions -fstack-protector 
--param=ssp-buffer-size=4 -m32 -march=i686 -mtune=atom 
-fasynchronous-unwind-tables -fPIC -DBOOST_PYTHON_NO_PY_SIGNATURES=1 
-DPYACTIVEMQ_ENABLE_DOCSTRINGS=0 -I/usr/include/activemq-cpp-3.3.0 
-I/usr/include/python2.7 -c src/main/Session.cpp -o 
build/temp.linux-i686-2.7/src/main/Session.o
src/main/Session.cpp:93:20: warning: 'AcknowledgeMode_docstring' defined but 
not used [-Wunused-variable]
gcc -pthread -DNDEBUG -O2 -g -pipe -Wall -Wp,-D_FORTIFY_SOURCE=2 -fexceptions 
-fstack-protector --param=ssp-buffer-size=4 -m32 -march=i686 -mtune=atom 
-fasynchronous-unwind-tables -D_GNU_SOURCE -fPIC -fwrapv -O2 -g -pipe -Wall 
-Wp,-D_FORTIFY_SOURCE=2 -fexceptions -fstack-protector 
--param=ssp-buffer-size=4 -m32 -march=i686 -mtune=atom 
-fasynchronous-unwind-tables -fPIC -DBOOST_PYTHON_NO_PY_SIGNATURES=1 
-DPYACTIVEMQ_ENABLE_DOCSTRINGS=0 -I/usr/include/activemq-cpp-3.3.0 
-I/usr/include/python2.7 -c src/main/TextMessage.cpp -o 
build/temp.linux-i686-2.7/src/main/TextMessage.o
gcc -pthread -DNDEBUG -O2 -g -pipe -Wall -Wp,-D_FORTIFY_SOURCE=2 -fexceptions 
-fstack-protector --param=ssp-buffer-size=4 -m32 -march=i686 -mtune=atom 
-fasynchronous-unwind-tables -D_GNU_SOURCE -fPIC -fwrapv -O2 -g -pipe -Wall 
-Wp,-D_FORTIFY_SOURCE=2 -fexceptions -fstack-protector 
--param=ssp-buffer-size=4 -m32 -march=i686 -mtune=atom 
-fasynchronous-unwind-tables -fPIC -DBOOST_PYTHON_NO_PY_SIGNATURES=1 
-DPYACTIVEMQ_ENABLE_DOCSTRINGS=0 -I/usr/include/activemq-cpp-3.3.0 
-I/usr/include/python2.7 -c src/main/CMSProperties.cpp -o 
build/temp.linux-i686-2.7/src/main/CMSProperties.o
gcc -pthread -DNDEBUG -O2 -g -pipe -Wall -Wp,-D_FORTIFY_SOURCE=2 -fexceptions 
-fstack-protector --param=ssp-buffer-size=4 -m32 -march=i686 -mtune=atom 
-fasynchronous-unwind-tables -D_GNU_SOURCE -fPIC -fwrapv -O2 -g -pipe -Wall 
-Wp,-D_FORTIFY_SOURCE=2 -fexceptions -fstack-protector 
--param=ssp-buffer-size=4 -m32 -march=i686 -mtune=atom 
-fasynchronous-unwind-tables -fPIC -DBOOST_PYTHON_NO_PY_SIGNATURES=1 
-DPYACTIVEMQ_ENABLE_DOCSTRINGS=0 -I/usr/include/activemq-cpp-3.3.0 
-I/usr/include/python2.7 -c src/main/ActiveMQConnectionFactory.cpp -o 
build/temp.linux-i686-2.7/src/main/ActiveMQConnectionFactory.o
src/main/ActiveMQConnectionFactory.cpp: In function 'void 
export_ActiveMQConnectionFactory()':
src/main/ActiveMQConnectionFactory.cpp:51:38: error: 'getBrokerURL' is not a 
member of 'activemq::core::ActiveMQConnectionFactory'
src/main/ActiveMQConnectionFactory.cpp:53:24: error: 'setBrokerURL' is not a 
member of 'activemq::core::ActiveMQConnectionFactory'
error: command 'gcc' failed with exit status 1

What version of the product are you using? On what operating system?

Head of SVN i.e rev 209.

Add docstrings to all the classes in the API.

Attached is a tool written with pyactivemq that lets you send messages from the 
command line (use pyCLProducer.py -h for details) It could be included in 
src/examples in the tar ball.

Compiling pyactivemq with libboost-python installed on Ubuntu Hardy [1]
throws some method signature errors:

src/main/pyactivemq.cpp: In function ‘void init_module_pyactivemq()’:
src/main/pyactivemq.cpp:96: error: no matching function for call to
‘boost::python::docstring_options::docstring_options(bool&, bool&, bool&)’
/usr/include/boost/python/docstring_options.hpp:25: note: candidates are:
boost::python::docstring_options::docstring_options(bool, bool)
/usr/include/boost/python/docstring_options.hpp:17: note:                
boost::python::docstring_options::docstring_options(bool)
/usr/include/boost/python/docstring_options.hpp:15: note:                
boost::python::docstring_options::docstring_options(const
boost::python::docstring_options&)

src/main/Session.cpp: In function ‘void export_Session()’:
src/main/Session.cpp:152: error: no matching function for call to
‘boost::python::enum_<cms::Session::AcknowledgeMode>::enum_(const char
[16], const char*&)’
/usr/include/boost/python/enum.hpp:37: note: candidates are:
boost::python::enum_<T>::enum_(const char*) [with T =
cms::Session::AcknowledgeMode]
/usr/include/boost/python/enum.hpp:18: note:                
boost::python::enum_<cms::Session::AcknowledgeMode>::enum_(const
boost::python::enum_<cms::Session::AcknowledgeMode>&)

The attached patches fixes things, but since I've never developed with
boost before, I don't know how sane it is (and presumably the current code
works for some version of libboost-python).

[1] Package info:
Package: libboost-python-dev
State: installed
Automatically installed: no
Version: 1.34.1-4ubuntu3

What steps will reproduce the problem?
1. Have a broker which uses simple Authentication for all queues and is
password protected
2. One python producer, producing 20 messages and sleeping after that < not
exiting the process> and one python Asynchronous consumer <different python
programs>
connecting to the same queue

What is the expected output? What do you see instead?
Expect Output --all messages  are received, in order

Actual Output - Not all messages are received -- Only alternate messages
are received -- And when the producer is killed, the alternate messages
that were not sent in the first place are received.

What version of the product are you using? On what operating system?
pyactivemq trunk, Ubuntu 

Please provide any additional information below.

Various tests can still be added:

1. Test all the MessageProducer#send methods.

2. Test that starting and stopping a Connection has the desired effect.

3. Check that operations on closed Connections/Sessions/Producers/Consumers
works (i.e. doesn't do anything and doesn't crash).

4. Test various other consumer options from here:

http://activemq.apache.org/cms/configuring.html

like Retroactive Consumer and Exclusive Consumer.

https://issues.apache.org/activemq/browse/AMQCPP-216
https://issues.apache.org/activemq/browse/AMQCPP-217

Return the derived Destination type (Queue, Topic, TemporaryQueue, 
TemporaryTopic) from message's replyTo and Destination properties, instead 
of simply a Destination.

It would be nice to have a version number to check.

$ python
>>> import pyactivemq
>>> print pyactivemq.version
(0, 0, 3)

Make MapMessage behave more like a Python map.

What steps will reproduce the problem?
1. Import pyactivemq
2.
3.

What is the expected output? What do you see instead?

When built with Visual Studio 8, the output is:

RuntimeError: extension class wrapper for base class class cms::Destination
has not been created yet

Please use labels and text to provide additional information.

DurableSubscriberExample.py doesn't work when using the Stomp wire format.

It hangs after the producer has sent its first batch of messages. The
consumer doesn't seem to receive anything.

What steps will reproduce the problem?
1. Build with Visual Studio 8 project files
2.
3.

What is the expected output? What do you see instead?

Library should link statically to Boost.Python. Somehow the auto_link magic
isn't kicking in.

Please use labels and text to provide additional information.

Maybe try to get this suggestion implemented:

http://www.nabble.com/::cms::Message-class-and-properties-td8802789.html

Also look at what happens when one sets two properties with the same name 
but different data types.

What steps will reproduce the problem?
1. Install activemq-cpp not in /opt
2. Try and compile pyactivemq
3. activemq-cpp header files can't be located.

What is the expected output? What do you see instead?
Look for activemq-cpp-config in default locations and 
maybe permit it to be passed in as a location or something.

What version of the product are you using? On what operating system?
Fedora 13 (currently rawhide).
pyactivemq-0.1.0 with activemq-cpp-2.2.6

Please provide any additional information below.

I've attached a patch which looks for /usr/bin/activemqcpp-config
as a hard coded location in preference to the defaults but 
this could probably be better.

Steve.

What steps will reproduce the problem?
1. build the module
2.
3.

What is the expected output? What do you see instead?
[root@castestclient pyactivemq-0.1.0]# /home//xmsong/python2.5.4/bin/python 
setup.py build
running build
running build_ext
building 'pyactivemq' extension
gcc -pthread -fno-strict-aliasing -DNDEBUG -g -fwrapv -O3 -Wall 
-Wstrict-prototypes -fPIC -DBOOST_PYTHON_NO_PY_SIGNATURES=1 
-DPYACTIVEMQ_ENABLE_DOCSTRINGS=0 
-I/opt/activemq-cpp-2.2.1/include/activemq-cpp-2.2.1 
-I/home/xmsong/python2.5.4/include/python2.5 -c src/main/pyactivemq.cpp -o 
build/temp.linux-x86_64-2.5/src/main/pyactivemq.o
cc1plus: warning: command line option "-Wstrict-prototypes" is valid for 
Ada/C/ObjC but not for C++
src/main/pyactivemq.cpp:27:27: error: cms/Startable.h: No such file or directory
src/main/pyactivemq.cpp:28:27: error: cms/Stoppable.h: No such file or directory
src/main/pyactivemq.cpp:29:27: error: cms/Closeable.h: No such file or directory
src/main/pyactivemq.cpp:30:30: error: cms/DeliveryMode.h: No such file or 
directory
src/main/pyactivemq.cpp:34: error: ‘cms’ has not been declared
src/main/pyactivemq.cpp:35: error: ‘cms’ has not been declared
src/main/pyactivemq.cpp:36: error: ‘cms’ has not been declared
src/main/pyactivemq.cpp: In constructor 
‘std_vector_to_tuple<T>::std_vector_to_tuple()’:
src/main/pyactivemq.cpp:59: error: ‘vector’ is not a member of ‘std’
src/main/pyactivemq.cpp:59: error: ‘vector’ is not a member of ‘std’
src/main/pyactivemq.cpp:59: error: wrong number of template arguments (1, 
should be 2)
/usr/include/boost/python/to_python_converter.hpp:17: error: provided for 
‘template<class T, class Conversion> struct 
boost::python::to_python_converter’
src/main/pyactivemq.cpp:59: error: expected unqualified-id before ‘,’ token
src/main/pyactivemq.cpp:59: error: ‘vector’ is not a member of ‘std’
src/main/pyactivemq.cpp:59: error: ‘vector’ is not a member of ‘std’
src/main/pyactivemq.cpp:59: error: template argument 1 is invalid
src/main/pyactivemq.cpp: In function ‘void init_module_pyactivemq()’:
src/main/pyactivemq.cpp:115: error: ‘Startable’ was not declared in this 
scope
src/main/pyactivemq.cpp:115: error: template argument 1 is invalid
src/main/pyactivemq.cpp:116: error: ‘Startable’ is not a class or namespace
src/main/pyactivemq.cpp:119: error: ‘Stoppable’ was not declared in this 
scope
src/main/pyactivemq.cpp:119: error: template argument 1 is invalid
src/main/pyactivemq.cpp:120: error: ‘Stoppable’ is not a class or namespace
src/main/pyactivemq.cpp:123: error: ‘Closeable’ was not declared in this 
scope
src/main/pyactivemq.cpp:123: error: template argument 1 is invalid
src/main/pyactivemq.cpp:124: error: ‘Closeable’ is not a class or namespace
src/main/pyactivemq.cpp:144: error: ‘cms’ was not declared in this scope
src/main/pyactivemq.cpp:144: error: template argument 1 is invalid
src/main/pyactivemq.cpp:147: error: ‘cms’ is not a class or namespace
src/main/pyactivemq.cpp:149: error: ‘cms’ is not a class or namespace
src/main/pyactivemq.cpp: At global scope:
src/main/pyactivemq.cpp:78: warning: ‘pyactivemq_docstring’ defined but not 
used
error: command 'gcc' failed with exit status 1
[root@castestclient pyactivemq-0.1.0]# 
[root@castestclient pyactivemq-0.1.0]# 
[root@castestclient pyactivemq-0.1.0]# ls
build  CHANGES.txt  LICENSE.txt  MANIFEST  PKG-INFO  setup.cfg  setup.py  src  
win_build

What version of the product are you using? On what operating system?
[root@castestclient examples]# arch
x86_64
[root@castestclient examples]# cat /etc/issue
CentOS release 5.3 (Final)
Kernel \r on an \m

[root@castestclient examples]# /home/xmsong/python2.5.4/bin/python -V
Python 2.5.4
[root@castestclient examples]# 

pyactivemq-0.1.0

Please provide any additional information below.
 cms/Startable.h: No such file or directory

Run stresstests.py for a long time on Windows.

We'll have to check if this problem also happens on Linux. If so, we can 
use Valgrind to debug it.

What steps will reproduce the problem?
1. Run unit tests repeatedly in quick succession
2.
3.

What is the expected output? What do you see instead?

Expected output:

<pyactivemq.TextMessage object at 0x009EB6C0>
<pyactivemq.BytesMessage object at 0x009EB6C0>

Actual output:

<pyactivemq.TextMessage object at 0x009EB6C0>
<pyactivemq.BytesMessage object at 0x009EB6C0>
<pyactivemq.CMSException object at 0x009EB6C0> :
StompConnector::enforceConnected - Not Connected!

Sometimes the Python crashes.

Please use labels and text to provide additional information.

OS Ubuntu 10.04 on VirtualBox
pyactivemq 0.2.0 in the trunck
ActiveMQ-cpp-3.4.1

When I compile pyactivemq I ve a error :
cc1plus: warning: command line option "-Wstrict-prototypes" is valid for 
Ada/C/ObjC but not for C++
gcc -pthread -fno-strict-aliasing -DNDEBUG -g -fwrapv -O2 -Wall 
-Wstrict-prototypes -fPIC -DBOOST_PYTHON_NO_PY_SIGNATURES=1 
-DPYACTIVEMQ_ENABLE_DOCSTRINGS=0 
-I/opt/activemq-cpp/03_04_01/include/activemq-cpp-3.4.1 
-I/usr/include/python2.6 -c src/main/MessageListener.cpp -o 
build/temp.linux-x86_64-2.6/src/main/MessageListener.o
cc1plus: warning: command line option "-Wstrict-prototypes" is valid for 
Ada/C/ObjC but not for C++
src/main/MessageListener.cpp:51: error: looser throw specifier for ‘virtual 
void MessageListenerWrap::onMessage(const cms::Message*)’
/opt/activemq-cpp/03_04_01/include/activemq-cpp-3.4.1/cms/MessageListener.h:55: 
error:   overriding ‘virtual void cms::MessageListener::onMessage(const 
cms::Message*) throw ()’
error: command 'gcc' failed with exit status 1

What steps will reproduce the problem?

I've created a script that subscribes to 2 topics as durable subscribers and 2 
queues as consumers.  The application works fine for several hours.  I am able 
to read messages from the topics and queues and send messages.  However after a 
few hours the application hangs (run from the command line--cygwin bash shell). 
 If I run it in PyCharm (python IDE) the application stops after the same few 
hours with exit code -1073741819 ( 0xC0000005) which is access violation. I 
registered an exception listener, but the onException() method is never called. 
I've tried valiantly to compile the code so I can run this in the debugger, but 
trunk does not compile, and I can't seem to find the right combination of 
Apache and the activemq project code to get it to compile.  I'd be happy to 
debug this if someone could provide more helpful hints on compilation.  I use 
VS2008 but also have VS2010 and could probably round up the VS2006 compiler on 
a different machine. 


What is the expected output? What do you see instead?
I would expect the activemq interface to continue working or tell my why it 
isn't working.  A thrown exception that I could catch and handle would be 
outstanding.

What version of the product are you using? On what operating system?
pyactivemq-0.1.0/python26/windows 7.

Please provide any additional information below.

The messages that this application gets are text XML docs.

Here are some code snippets (this wouldn't run without the extra code around 
it, but is provided so you can see the basics of how I'm using the pyqctivemq 
interface).




###########################################################################
class TextListener(pyactivemq.MessageListener):
    def __init__(self, name, parent):
        pyactivemq.MessageListener.__init__(self)
        self.monitor = Event()
        self.name = name
        self.msgCount = 0
        self.parent= parent # The parent object
    #######################################################################
    def onMessage(self, message):
        if isinstance(message, pyactivemq.TextMessage):
            try:
                #print ('%s: Reading Message: ' % self.name) + message.text
                self.msgCount += 1
                try:
                    self.parent.msgQ.put(
                        (self.name,message.text),timeout=60)
                except Queue.Full:
                    print("Queue is full or blocking!")

            except:
                print("Failed to put message on the queue")
                print(traceback.format_exc())
        else:
            self.monitor.set()

###########################################################################

class ExceptionListener(pyactivemq.ExceptionListener):
    def __init__(self,parent):
        self.parent= parent
        pyactivemq.ExceptionListener.__init__(self)
        #TODO: What goes in here?
    def onException(self,ex):
        print("Fatal exception?  Shutting down.")
        print(traceback.format_exc(10))
        sys.exit(-999)
###########################################################################
###########################################################################
def startRegularSubscriber(self):
    print('Starting regular subscriber')
    topicName = 'regular.update.topic'

    self.updateTopic = self.session.createTopic(topicName)
    self.connection.stop()
    self.regularSubscriber = self.session.createDurableConsumer(self.updateTopic, 
        "MakeItLast", '', False)
    self.regularSubscriber.messageListener = self.TextListener('reg',self)
    print('Subscribed to %s' % topicName)
    self.connection.start()
    print("Started connection")

###########################################################################
def startEodSubscriber(self):
    print('Starting eod subscriber')
    topicName = 'eod.update.topic'

    self.eodTopic = self.session.createTopic(topicName)
    self.connection.stop()
    self.eodSubscriber = self.session.createDurableConsumer(self.eodTopic, 
        "MakeItLast2", '', False)
    self.eodSubscriber.messageListener = self.TextListener('eod',self)
    print('Subscribed to %s' % topicName)
    self.connection.start()
    print("Started connection")

###########################################################################

connection = connectionFactory.createConnection('', '', clientID)
print('Connection has ID %s' % connection.clientID)
ex= ExceptionListener(self)
connection.exceptionListener= ex 

session = connection.createSession(AcknowledgeMode.AUTO_ACKNOWLEDGE)

rqstQueue = session.createQueue('report.request.queue')
rqstProducer = session.createProducer(rqstQueue)

clientQueueName = 'client.specific.update.queue'
clientQueue = session.createQueue(clientQueueName)

clientSelector = "ClientId='%s'" % connection.clientID
print('CS = %s' % clientSelector)
clientSubscriber = session.createConsumer(clientQueue, 
    clientSelector, True)

clientSubscriber.messageListener = TextListener('client',self)
print('Subscribed to %s' % clientQueueName)

connection.start()

print("Started connection")



startRegularSubscriber()
time.sleep(5) # Adding a sleep between subscriptions seems to prevent
              # Re-connect issues.  I'm not sure why.
startEodSubscriber()
time.sleep(5)

There are two sporadic crashes that show up when running the test suite
repeatedly on Windows.

In the main thread it crashes with the following stack trace:

{{{
>   pyactivemq.pyd!activemq::core::ActiveMQSession::close()  Line 110 + 0x8
bytes   C++
    pyactivemq.pyd!activemq::core::ActiveMQSession::~ActiveMQSession()  Line
74 + 0x8 bytes  C++
    pyactivemq.pyd!activemq::core::ActiveMQSession::`scalar deleting
destructor'()  + 0xf bytes  C++
    pyactivemq.pyd!std::auto_ptr<cms::Session>::~auto_ptr<cms::Session>() 
Line 718 + 0x36 bytes   C++

pyactivemq.pyd!boost::python::objects::pointer_holder<std::auto_ptr<cms::Session
>,cms::Session>::~pointer_holder<std::auto_ptr<cms::Session>,cms::Session>()
 + 0x54 bytes   C++

pyactivemq.pyd!boost::python::objects::pointer_holder<std::auto_ptr<cms::Session
>,cms::Session>::`scalar
deleting destructor'()  + 0x2b bytes    C++
    pyactivemq.pyd!instance_dealloc(_object * inst=0x00a65308)  Line 282    C++
    python24.dll!1e0ab7d6()     
    [Frames below may be incorrect and/or missing, no symbols loaded for
python24.dll]   
    pyactivemq.pyd!life_support_call(_object * self=0x0099d0c0, _object *
arg=0x00a62fd0, _object * kw=0x00000000)  Line 30 + 0x40 bytes  C++
    python24.dll!1e018f3c()     
    python24.dll!1e019038()     
    python24.dll!1e0c042c()     
    python24.dll!1e0c051d()     
    pyactivemq.pyd!instance_dealloc(_object * inst=0x00a65260)  Line 282 +
0x16 bytes  C++
}}}

In one of other threads it sometimes crashes with:

{{{
>   pyactivemq.pyd!activemq::io::BufferedInputStream::read()  Line 79 +
0x12 bytes  C++

pyactivemq.pyd!activemq::connector::stomp::StompCommandReader::readStompHeaderLi
ne()
 Line 194 + 0x19 bytes  C++

pyactivemq.pyd!activemq::connector::stomp::StompCommandReader::readStompHeaders(
activemq::connector::stomp::StompFrame
& frame={...})  Line 136 + 0xb bytes    C++

pyactivemq.pyd!activemq::connector::stomp::StompCommandReader::readCommand()
 Line 62    C++
    pyactivemq.pyd!activemq::transport::IOTransport::run()  Line 166 + 0x19
bytes   C++
    pyactivemq.pyd!activemq::concurrent::Thread::runCallback(void *
param=0x00f00040)  Line 152 + 0x13 bytes    C++
    msvcr80d.dll!_callthreadstartex()  Line 348 + 0xf bytes C
    msvcr80d.dll!_threadstartex(void * ptd=0x00f57d38)  Line 331    C
}}}

See attached setup.cfg for [egg_info] and [epydoc] configuration options that 
should be placed in 
the root of the project. When you tag a version you get rid of the [egg_info] 
section in the 
setup.cfg.

To use it with epydoc run: epydoc --config=setup.cfg

Integrate properly with the Python code module.

The various clone member functions will probably be useful here.

Some of the Message properties are set by the message broker and should be
made read-only from the Python user's perspective.

1. send messages to non-durable topic with asynchronous consumer
2. try and stop() the connection or close() the consumer/session/connection
3. process flow hangs

Should expect to see the methods returning cleanly and message flow
stopping. Instead, the method doesn't return (blocks)

Experienced this on linux with ActiveMQ 5.1 5.2 & 5.3, ActiveMQ-CPP-2.2.1
built pyactivemq from 0.1.0.

https://issues.apache.org/activemq/browse/AMQCPP-199