pyicat_plus.client.messaging.IcatMessagingClient

class pyicat_plus.client.messaging.IcatMessagingClient(queue_urls, queue_name, monitor_port=None, timeout=None)

Bases: object

Client for the ICAT message broker.

The message broker is currently ActiveMQ, a message broker using the STOMP protocol. It also has a REST server for monitoring the broker status.

Parameters:

• queue_urls (List[str])

• queue_name (str)

• monitor_port (Optional[int])

• timeout (Optional[float])

DEFAULT_MONITOR_PORT = 8778

DEFAULT_PORT = 61613

DEFAULT_SCHEME = 'tcp'

MONITOR_PWD = 'user'

MONITOR_SCHEME = 'http'

MONITOR_USER = 'user'

check_health()

Raises an exception when: - not connected - no message consumers

disconnect()

reconnect()

send(data)

Parameters:

data (bytes)