You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@qpid.apache.org by "Weatherby,Gerard" <gw...@uchc.edu> on 2020/09/03 13:49:30 UTC
Example not working?
I tried to setup Apache Qpid on Ubuntu 18.04 doing the following:
sudo add-apt-repository ppa:qpid/released
sudo apt install qpidd
which gave me:
qpidd/bionic,now 1.39.0-3qpid+bionic1 amd64 [installed]
I then tried using the tutorial example:
—
from __future__ import print_function, unicode_literals
from proton import Message
from proton.handlers import MessagingHandler
from proton.reactor import Container
class HelloWorld(MessagingHandler):
def __init__(self, server, address):
super(HelloWorld, self).__init__()
self.server = server
self.address = address
def on_start(self, event):
conn = event.container.connect(self.server)
event.container.create_receiver(conn, self.address)
event.container.create_sender(conn, self.address)
def on_sendable(self, event):
event.sender.send(Message(body="Hello World!"))
event.sender.close()
def on_message(self, event):
print(event.message.body)
event.connection.close()
Container(HelloWorld("localhost:5672", "examples")).run()
—
This happens:
python tut.py
ERROR:root:Node not found: examples
ERROR:root:Node not found: examples
—
and the server says pretty much the same thing:
sudo journalctl -u qpidd --since '4 min ago'
-- Logs begin at Tue 2019-06-18 09:30:35 EDT, end at Thu 2020-09-03 09:48:05 EDT. --
Sep 03 09:46:53 nmrdev qpidd[2604067]: 2020-09-03 09:46:53 [Protocol] error Error on attach: Node not found: examples
--
Gerard Weatherby | Application Architect
NMRbox | Department of Molecular Biology and Biophysics | UConn Health
263 Farmington Avenue, Farmington, CT 06030-6406
uchc.edu<http://uchc.edu>
Re: Persistent queue
Posted by "Weatherby,Gerard" <gw...@uchc.edu>.
Thanks again, that did the trick.
Specifically:
apt-get install liblinearstore
and add
load-module=/usr/lib/x86_64-linux-gnu/qpid/daemon/linearstore.so to /etc/qpid/qpidd.conf
and
using durable to create queues.
Ubuntu18.04 system.
--
Gerard Weatherby | Application Architect
NMRbox | Department of Molecular Biology and Biophysics | UConn Health
263 Farmington Avenue, Farmington, CT 06030-6406
uchc.edu<http://uchc.edu>
On Sep 7, 2020, at 3:33 AM, Robbie Gemmell <ro...@gmail.com>> wrote:
*** Attention: This is an external email. Use caution responding, opening attachments or clicking on links. ***
My guess would be to ensure it is loading the store module
(linearstore?), perhaps investigate the --module-dir and --load-module
options.
On Sun, 6 Sep 2020 at 23:15, Weatherby,Gerard <gw...@uchc.edu>> wrote:
I’ve be able to create a queue and have clients communicate using
qpid-config add queue address
or
qpid-config add queue —durable address
however the queue is lost when the qpidd systemd service is restarted. Is there a way to have the queue created when qpidd starts?
--
Gerard Weatherby | Application Architect
NMRbox | Department of Molecular Biology and Biophysics | UConn Health
263 Farmington Avenue, Farmington, CT 06030-6406
uchc.edu<http://uchc.edu><http://uchc.edu>
Re: Persistent queue
Posted by Gordon Sim <gs...@redhat.com>.
On 07/09/2020 8:33 am, Robbie Gemmell wrote:
> My guess would be to ensure it is loading the store module
> (linearstore?), perhaps investigate the --module-dir and --load-module
> options.
Also make sure you use the durable option when creating the queue. If it
already exists it won't be updated to be durable.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Re: Persistent queue
Posted by Robbie Gemmell <ro...@gmail.com>.
My guess would be to ensure it is loading the store module
(linearstore?), perhaps investigate the --module-dir and --load-module
options.
On Sun, 6 Sep 2020 at 23:15, Weatherby,Gerard <gw...@uchc.edu> wrote:
>
> I’ve be able to create a queue and have clients communicate using
>
> qpid-config add queue address
> or
> qpid-config add queue —durable address
>
> however the queue is lost when the qpidd systemd service is restarted. Is there a way to have the queue created when qpidd starts?
> --
> Gerard Weatherby | Application Architect
> NMRbox | Department of Molecular Biology and Biophysics | UConn Health
> 263 Farmington Avenue, Farmington, CT 06030-6406
> uchc.edu<http://uchc.edu>
>
> On Sep 3, 2020, at 10:28 AM, Weatherby,Gerard <gw...@uchc.edu>> wrote:
>
> *** Attention: This is an external email. Use caution responding, opening attachments or clicking on links. ***
>
> Thanks.
>
> For message list posterity, ‘qpid-config’ is in debian pacakge ‘qpid-tools'
> --
> Gerard Weatherby | Application Architect
> NMRbox | Department of Molecular Biology and Biophysics | UConn Health
> 263 Farmington Avenue, Farmington, CT 06030-6406
> uchc.edu<http://uchc.edu/><http://uchc.edu<http://uchc.edu/>>
>
> On Sep 3, 2020, at 10:11 AM, Gordon Sim <gs...@redhat.com>> wrote:
>
> *** Attention: This is an external email. Use caution responding, opening attachments or clicking on links. ***
>
> On 03/09/2020 2:49 pm, Weatherby,Gerard wrote:
> I tried to setup Apache Qpid on Ubuntu 18.04 doing the following:
>
> sudo add-apt-repository ppa:qpid/released
> sudo apt install qpidd
> which gave me:
> qpidd/bionic,now 1.39.0-3qpid+bionic1 amd64 [installed]
>
> I then tried using the tutorial example:
>
> —
> from __future__ import print_function, unicode_literals
> from proton import Message
> from proton.handlers import MessagingHandler
> from proton.reactor import Container
>
> class HelloWorld(MessagingHandler):
> def __init__(self, server, address):
> super(HelloWorld, self).__init__()
> self.server = server
> self.address = address
>
> def on_start(self, event):
> conn = event.container.connect(self.server)
> event.container.create_receiver(conn, self.address)
> event.container.create_sender(conn, self.address)
>
> def on_sendable(self, event):
> event.sender.send(Message(body="Hello World!"))
> event.sender.close()
>
> def on_message(self, event):
> print(event.message.body)
> event.connection.close()
>
> Container(HelloWorld("localhost:5672", "examples")).run()
> —
> This happens:
> python tut.py
> ERROR:root:Node not found: examples
> ERROR:root:Node not found: examples
> —
> and the server says pretty much the same thing:
> sudo journalctl -u qpidd --since '4 min ago'
> -- Logs begin at Tue 2019-06-18 09:30:35 EDT, end at Thu 2020-09-03 09:48:05 EDT. --
> Sep 03 09:46:53 nmrdev qpidd[2604067]: 2020-09-03 09:46:53 [Protocol] error Error on attach: Node not found: examples
>
> You need to create a queue called 'examples'. You can do that with
> qpid-config.
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org<ma...@qpid.apache.org>
> For additional commands, e-mail: users-help@qpid.apache.org<ma...@qpid.apache.org>
>
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org
Persistent queue
Posted by "Weatherby,Gerard" <gw...@uchc.edu>.
I’ve be able to create a queue and have clients communicate using
qpid-config add queue address
or
qpid-config add queue —durable address
however the queue is lost when the qpidd systemd service is restarted. Is there a way to have the queue created when qpidd starts?
--
Gerard Weatherby | Application Architect
NMRbox | Department of Molecular Biology and Biophysics | UConn Health
263 Farmington Avenue, Farmington, CT 06030-6406
uchc.edu<http://uchc.edu>
On Sep 3, 2020, at 10:28 AM, Weatherby,Gerard <gw...@uchc.edu>> wrote:
*** Attention: This is an external email. Use caution responding, opening attachments or clicking on links. ***
Thanks.
For message list posterity, ‘qpid-config’ is in debian pacakge ‘qpid-tools'
--
Gerard Weatherby | Application Architect
NMRbox | Department of Molecular Biology and Biophysics | UConn Health
263 Farmington Avenue, Farmington, CT 06030-6406
uchc.edu<http://uchc.edu/><http://uchc.edu<http://uchc.edu/>>
On Sep 3, 2020, at 10:11 AM, Gordon Sim <gs...@redhat.com>> wrote:
*** Attention: This is an external email. Use caution responding, opening attachments or clicking on links. ***
On 03/09/2020 2:49 pm, Weatherby,Gerard wrote:
I tried to setup Apache Qpid on Ubuntu 18.04 doing the following:
sudo add-apt-repository ppa:qpid/released
sudo apt install qpidd
which gave me:
qpidd/bionic,now 1.39.0-3qpid+bionic1 amd64 [installed]
I then tried using the tutorial example:
—
from __future__ import print_function, unicode_literals
from proton import Message
from proton.handlers import MessagingHandler
from proton.reactor import Container
class HelloWorld(MessagingHandler):
def __init__(self, server, address):
super(HelloWorld, self).__init__()
self.server = server
self.address = address
def on_start(self, event):
conn = event.container.connect(self.server)
event.container.create_receiver(conn, self.address)
event.container.create_sender(conn, self.address)
def on_sendable(self, event):
event.sender.send(Message(body="Hello World!"))
event.sender.close()
def on_message(self, event):
print(event.message.body)
event.connection.close()
Container(HelloWorld("localhost:5672", "examples")).run()
—
This happens:
python tut.py
ERROR:root:Node not found: examples
ERROR:root:Node not found: examples
—
and the server says pretty much the same thing:
sudo journalctl -u qpidd --since '4 min ago'
-- Logs begin at Tue 2019-06-18 09:30:35 EDT, end at Thu 2020-09-03 09:48:05 EDT. --
Sep 03 09:46:53 nmrdev qpidd[2604067]: 2020-09-03 09:46:53 [Protocol] error Error on attach: Node not found: examples
You need to create a queue called 'examples'. You can do that with
qpid-config.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org<ma...@qpid.apache.org>
For additional commands, e-mail: users-help@qpid.apache.org<ma...@qpid.apache.org>
Persistent queue
Posted by "Weatherby,Gerard" <gw...@uchc.edu>.
I’ve be able to create a queue and have clients communicate using
qpid-config add queue address
or
qpid-config add queue —durable address
however the queue is lost when the qpidd systemd service is restarted. Is there a way to have the queue created when qpidd starts?
--
Gerard Weatherby | Application Architect
NMRbox | Department of Molecular Biology and Biophysics | UConn Health
263 Farmington Avenue, Farmington, CT 06030-6406
uchc.edu<http://uchc.edu>
On Sep 3, 2020, at 10:28 AM, Weatherby,Gerard <gw...@uchc.edu>> wrote:
*** Attention: This is an external email. Use caution responding, opening attachments or clicking on links. ***
Thanks.
For message list posterity, ‘qpid-config’ is in debian pacakge ‘qpid-tools'
--
Gerard Weatherby | Application Architect
NMRbox | Department of Molecular Biology and Biophysics | UConn Health
263 Farmington Avenue, Farmington, CT 06030-6406
uchc.edu<http://uchc.edu/><http://uchc.edu<http://uchc.edu/>>
On Sep 3, 2020, at 10:11 AM, Gordon Sim <gs...@redhat.com>> wrote:
*** Attention: This is an external email. Use caution responding, opening attachments or clicking on links. ***
On 03/09/2020 2:49 pm, Weatherby,Gerard wrote:
I tried to setup Apache Qpid on Ubuntu 18.04 doing the following:
sudo add-apt-repository ppa:qpid/released
sudo apt install qpidd
which gave me:
qpidd/bionic,now 1.39.0-3qpid+bionic1 amd64 [installed]
I then tried using the tutorial example:
—
from __future__ import print_function, unicode_literals
from proton import Message
from proton.handlers import MessagingHandler
from proton.reactor import Container
class HelloWorld(MessagingHandler):
def __init__(self, server, address):
super(HelloWorld, self).__init__()
self.server = server
self.address = address
def on_start(self, event):
conn = event.container.connect(self.server)
event.container.create_receiver(conn, self.address)
event.container.create_sender(conn, self.address)
def on_sendable(self, event):
event.sender.send(Message(body="Hello World!"))
event.sender.close()
def on_message(self, event):
print(event.message.body)
event.connection.close()
Container(HelloWorld("localhost:5672", "examples")).run()
—
This happens:
python tut.py
ERROR:root:Node not found: examples
ERROR:root:Node not found: examples
—
and the server says pretty much the same thing:
sudo journalctl -u qpidd --since '4 min ago'
-- Logs begin at Tue 2019-06-18 09:30:35 EDT, end at Thu 2020-09-03 09:48:05 EDT. --
Sep 03 09:46:53 nmrdev qpidd[2604067]: 2020-09-03 09:46:53 [Protocol] error Error on attach: Node not found: examples
You need to create a queue called 'examples'. You can do that with
qpid-config.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org<ma...@qpid.apache.org>
For additional commands, e-mail: users-help@qpid.apache.org<ma...@qpid.apache.org>
Re: Example not working?
Posted by "Weatherby,Gerard" <gw...@uchc.edu>.
Thanks.
For message list posterity, ‘qpid-config’ is in debian pacakge ‘qpid-tools'
--
Gerard Weatherby | Application Architect
NMRbox | Department of Molecular Biology and Biophysics | UConn Health
263 Farmington Avenue, Farmington, CT 06030-6406
uchc.edu<http://uchc.edu>
On Sep 3, 2020, at 10:11 AM, Gordon Sim <gs...@redhat.com>> wrote:
*** Attention: This is an external email. Use caution responding, opening attachments or clicking on links. ***
On 03/09/2020 2:49 pm, Weatherby,Gerard wrote:
I tried to setup Apache Qpid on Ubuntu 18.04 doing the following:
sudo add-apt-repository ppa:qpid/released
sudo apt install qpidd
which gave me:
qpidd/bionic,now 1.39.0-3qpid+bionic1 amd64 [installed]
I then tried using the tutorial example:
—
from __future__ import print_function, unicode_literals
from proton import Message
from proton.handlers import MessagingHandler
from proton.reactor import Container
class HelloWorld(MessagingHandler):
def __init__(self, server, address):
super(HelloWorld, self).__init__()
self.server = server
self.address = address
def on_start(self, event):
conn = event.container.connect(self.server)
event.container.create_receiver(conn, self.address)
event.container.create_sender(conn, self.address)
def on_sendable(self, event):
event.sender.send(Message(body="Hello World!"))
event.sender.close()
def on_message(self, event):
print(event.message.body)
event.connection.close()
Container(HelloWorld("localhost:5672", "examples")).run()
—
This happens:
python tut.py
ERROR:root:Node not found: examples
ERROR:root:Node not found: examples
—
and the server says pretty much the same thing:
sudo journalctl -u qpidd --since '4 min ago'
-- Logs begin at Tue 2019-06-18 09:30:35 EDT, end at Thu 2020-09-03 09:48:05 EDT. --
Sep 03 09:46:53 nmrdev qpidd[2604067]: 2020-09-03 09:46:53 [Protocol] error Error on attach: Node not found: examples
You need to create a queue called 'examples'. You can do that with
qpid-config.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org<ma...@qpid.apache.org>
For additional commands, e-mail: users-help@qpid.apache.org<ma...@qpid.apache.org>
Re: Example not working?
Posted by Gordon Sim <gs...@redhat.com>.
On 03/09/2020 2:49 pm, Weatherby,Gerard wrote:
> I tried to setup Apache Qpid on Ubuntu 18.04 doing the following:
>
> sudo add-apt-repository ppa:qpid/released
> sudo apt install qpidd
> which gave me:
> qpidd/bionic,now 1.39.0-3qpid+bionic1 amd64 [installed]
>
> I then tried using the tutorial example:
>
> —
> from __future__ import print_function, unicode_literals
> from proton import Message
> from proton.handlers import MessagingHandler
> from proton.reactor import Container
>
> class HelloWorld(MessagingHandler):
> def __init__(self, server, address):
> super(HelloWorld, self).__init__()
> self.server = server
> self.address = address
>
> def on_start(self, event):
> conn = event.container.connect(self.server)
> event.container.create_receiver(conn, self.address)
> event.container.create_sender(conn, self.address)
>
> def on_sendable(self, event):
> event.sender.send(Message(body="Hello World!"))
> event.sender.close()
>
> def on_message(self, event):
> print(event.message.body)
> event.connection.close()
>
> Container(HelloWorld("localhost:5672", "examples")).run()
> —
> This happens:
> python tut.py
> ERROR:root:Node not found: examples
> ERROR:root:Node not found: examples
> —
> and the server says pretty much the same thing:
> sudo journalctl -u qpidd --since '4 min ago'
> -- Logs begin at Tue 2019-06-18 09:30:35 EDT, end at Thu 2020-09-03 09:48:05 EDT. --
> Sep 03 09:46:53 nmrdev qpidd[2604067]: 2020-09-03 09:46:53 [Protocol] error Error on attach: Node not found: examples
You need to create a queue called 'examples'. You can do that with
qpid-config.
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscribe@qpid.apache.org
For additional commands, e-mail: users-help@qpid.apache.org