Index

A

• --apply-to queues command / Refactoring queues
• addressee_id field / Implementing the back-office sender
• AMQP
  • about / Meet AMQP
  • broker / Meet AMQP
  • virtual host / Meet AMQP
  • connection / Meet AMQP
  • channel / Meet AMQP
  • exchange / Meet AMQP
  • queue / Meet AMQP
  • binding / Meet AMQP
  • load testing / Load testing AMQP
• AMQP 0-9-1 specification
  • URL, for downloading / Meet AMQP
• AMQP 1.0
  • about / The RabbitMQ broker
• AMQP appender
  • URL / Publishing and consuming logs
• AMQP message
  • structure / AMQP message structure
• arguments / Building the inbox
• asyncWaitAndReconnect method / Connecting to RabbitMQ
• authentication-service queue / Exposing the authentication service, Calling the authentication service
• authentication messages
  • about / Authentication messages
  • login request message / Request
  • login response message / Response
  • logout request message / Logout, Request
  • logout response message / Response
• authentication service
  • exposing / Exposing the authentication service
  • calling / Calling the authentication service
• autoDelete / Building the inbox

B

• Babysitting subscriptions
  • about / Babysitting subscriptions
• back-office sender
  • implementing / Implementing the back-office sender
• basicConsume / Creating a consumer subscription wrapper
• basicGet / Fetching user messages
• Beetle
  • URL / Connecting to RabbitMQ
• Bevis
  • URL / Publishing and consuming logs
• binding
  • about / Meet AMQP
• broker
  • about / Meet AMQP, The RabbitMQ broker, Tackling the broker SPOF
  • installing / Installing the broker
  • queues, mirroring / Mirroring queues
  • cluster, connecting to / Connecting to the cluster
  • federating / Federating brokers
  • monitoring / Monitoring the broker

C

• CCM
  • about / A case for RabbitMQ, Connecting to RabbitMQ, Moving beyond polling
  • consumer subscription wrapper, creating / Creating a consumer subscription wrapper
  • application, running / Running the application, Running the application
• channel
  • about / Meet AMQP
• ChannelCallable classs / Unit testing RabbitMQ applications
• ChannelCallable description / Working with channels
• ChannelCallable instance / Working with channels
• channels
  • working with / Working with channels
  • open channel / Working with channels
• cluster size / Monitoring the broker
• cluster_status command / Tackling the broker SPOF
• connection
  • about / Meet AMQP
• connectionFactory / Unit testing RabbitMQ applications
• connectionFactory mock / Unit testing RabbitMQ applications
• connections
  • about / Seeing it run
• consumer field / Creating a consumer subscription wrapper
• consumer subscription wrapper
  • creating / Creating a consumer subscription wrapper
• contentEncoding / Sending user messages
• contentType / Sending user messages
• CorrelationID / Exposing the authentication service
• CorrelationId message property / Replying to queues

D

• Dead Letter Exchange (DLX) / Handling dead letters
• Dead Letter Queue (DLQ) / Handling dead letters
• dead letters
  • handling / Handling dead letters
• declareUserMessageQueue method / Sending user messages, Refactoring queues
• delivery
  • making, mandatory / Making delivery mandatory
• delivery-mode / Exposing the authentication service
• deliveryMode / Sending user messages
• direct routing
  • building / Sending user messages
• durable / Building the inbox

E

• Erlang Port Mapper Daemom (epmd) / Monitoring the broker
• Erlang processes / Monitoring the broker
• exchange
  • about / Meet AMQP
  • properties / Building the inbox
  / Undertaking messages
• exclusive / Building the inbox

F

• Failsafe Maven plug-in
  • URL / Integration testing RabbitMQ applications
• fanout
  • binding to / Binding to the fanout
• federation plug-in / Federating brokers
• federation status / Monitoring the broker
• file descriptors / Monitoring the broker
• finalize method / Creating a consumer subscription wrapper
• Firehose / Drinking at the Firehose

G

• generic error message
  • about / Generic error message
• getAddress() method / Unit testing RabbitMQ applications
• getChannel method / Creating a consumer subscription wrapper

H

• ha-params parameter / Mirroring queues
• ha-sync-mode parameter / Mirroring queues
• handleDelivery method / Consuming queues, Creating a consumer subscription wrapper, Integration testing RabbitMQ applications
• handleDelivery method / Creating a consumer subscription wrapper
• handleException method / Exposing the authentication service
• HDF5
  • URL / Publishing and consuming logs

I

• immediate / Making delivery mandatory
• inbox
  • building / Building the inbox
• InetAddress instance / Unit testing RabbitMQ applications
• installation
  • broker / Installing the broker
  • management plugin / Installing the management plugin
• integration testing
  • RabbitMQ applications / Integration testing RabbitMQ applications
• isOpen method / Working with channels

J

• JMS
  • about / Meet AMQP
• join_cluster command / Tackling the broker SPOF
• JUnit / Unit testing RabbitMQ applications

L

• load testing
  • AMQP / Load testing AMQP
  • running / Running a load test
• login operation / Login
• login request message / Request
• login response message / Response
• logout operation / Logout
• logout request message / Request
• logout response message / Response
• logs
  • publishing / Publishing and consuming logs
  • consuming / Publishing and consuming logs
  • Bevis / Publishing and consuming logs
  • AMQP appender / Publishing and consuming logs
• loosely coupled architecture
  • about / A loosely coupled architecture

M

• management plugin
  • installing / Installing the management plugin
• mandatory delivery / Making delivery mandatory
• memory and disk space / Monitoring the broker
• message
  • publishing / Sending user messages
• message brokers / What is messaging?
• messageId / Sending user messages
• messages
  • prefetching / Prefetching messages
  • advantages / Messaging serendipity
  • about / Undertaking messages
• messaging
  • about / What is messaging?
• mirrored queues / Mirroring queues
• Mocha
  • URL / Unit testing RabbitMQ applications
• Mockito
  • URL / Unit testing RabbitMQ applications
• MQTT
  • about / Meet AMQP
• Mule AMQP
  • URL / Connecting to RabbitMQ
• multitenancy
  • about / Meet AMQP
• ØMQ
  • about / Meet AMQP

N

• newConnection method / Unit testing RabbitMQ applications
• node liveness / Monitoring the broker

O

• onApplicationStart method / Building the inbox, Adding topic messages, Undertaking messages

P

• -p ccm-dev-vhostctl set_policy command / Refactoring queues
• PerfTest / Tracing RabbitMQ
• policies / Refactoring queues
• prefetching / Prefetching messages
• Publish message section / Messaging serendipity

Q

• queue
  • about / Meet AMQP
  / Undertaking messages
• queues
  • consuming / Consuming queues
  • publishing to / Publishing to all queues
  • fanout, binding to / Binding to the fanout
  • publishing to all / Publishing to all
  • application, running / Running the application
  • refactoring / Refactoring queues
  • mirroring / Mirroring queues
• queues high-watermarks / Monitoring the broker
• Q_TTL_DLX command / Refactoring queues

R

• RabbitMQ
  • broker / The RabbitMQ broker
  • connecting to / Connecting to RabbitMQ
  • tracing / Tracing RabbitMQ
• rabbitmq-server / Monitoring the broker
• rabbitmqadmin / Undertaking messages
• RabbitMQ application
  • testing / Testing RabbitMQ applications
  • unit testing / Unit testing RabbitMQ applications
  • integration testing / Integration testing RabbitMQ applications
• rabbitmqctl command-line tool / Monitoring the broker
• RabbitMqManager / Unit testing RabbitMQ applications
• RabbitMQManager class / Unit testing RabbitMQ applications
• RabbitMqManager class / Connecting to RabbitMQ, Babysitting subscriptions, Connecting to the cluster, Unit testing RabbitMQ applications
• reason / Undertaking messages
• reply-to property / Replying to queues
• request-response style of interaction / What is messaging?
• respond method / Exposing the authentication service
• Rich Internet Application / Connecting to RabbitMQ
• Rich Internet Application (RIA) / A case for RabbitMQ
• routing key / Building the inbox
• routing keys / Undertaking messages

S

• security cookie / Tackling the broker SPOF
• sendUserMessage class / Sending user messages
• server-push approach / Moving beyond polling
• Service-oriented Architecture (SOA) / Service-oriented messaging
• service-oriented messaging
  • about / Service-oriented messaging
  • queues, replying to / Replying to queues, Routing service requests
  • service requests, routing / Routing service requests
• severity.facility / Publishing and consuming logs
• shovel plug-in / Federating brokers
• shutdownCompleted method / Connecting to RabbitMQ
• single point of failure (SPOF) / Tackling the broker SPOF
• SMTP / A loosely coupled architecture
• socket descriptors / Monitoring the broker
• Spring AMQP
  • URL / Connecting to RabbitMQ
• start() method / Unit testing RabbitMQ applications
• start method / Connecting to RabbitMQ
• stop method / Creating a consumer subscription wrapper
• store_log_data function / Publishing and consuming logs
• sudo rabbitmqctl set_policy command / Refactoring queues
• Surefire plug-in
  • URL / Unit testing RabbitMQ applications
• SUT (System Under Test) / Unit testing RabbitMQ applications

T

• time / Undertaking messages
• topic! / Adding topic messages
• topic messages
  • adding / Adding topic messages
• toString method / Creating a consumer subscription wrapper
• Tracer / Tracing RabbitMQ

U

• unit testing
  • RabbitMQ applications / Unit testing RabbitMQ applications
• upstreams / Federating brokers
• user-fanout exchange / Publishing to all
• user messages
  • sending / Sending user messages
  • fetching / Fetching user messages
• user message schema
  • about / User message
• UserMessageServerEndpoint / Tying into the WebSocket endpoint
• users
  • configuring / Configuring users

V

• vhost / Configuring users

W

• WebSocket
  • about / Moving beyond polling
  • URL / Moving beyond polling
  • endpoint, typing into / Tying into the WebSocket endpoint
• WebSocket endpoint
  • typing into / Tying into the WebSocket endpoint