Conectar uma aplicação Java ao agente do Amazon MQ

Faça login no console do Amazon MQ.

Na lista de corretores, escolha o nome do seu corretor (por exemplo, MyBroker).

Na MyBrokerpágina, na seção Conexões, observe os endereços e portas do URL do console web e dos protocolos de nível de fio do broker.

Na seção Details (Detalhes), em Security and network (Segurança e rede), escolha o nome do seu grupo de segurança ou .

A página Grupos de segurança do painel do EC2 é exibida.

Na lista de security group, escolha seu security group.

Na parte inferior da página, escolha Inbound (Entrada) e a seguir selecione Edit (Editar).

Na caixa de diálogo Edit inbound rules (Editar regras de entrada), adicione uma regra para cada URL ou endpoint que você deseja que seja acessível publicamente (o exemplo a seguir mostra como fazer isso para um console da Web do agente).

1. Escolha Add Rule (Adicionar regra).

2. Em Type (Tipo), selecione Custom TCP (TCP personalizado).

3. Para o Intervalo de Portas, digite a porta do console da Web (8162).

4. Para Source (Origem), deixe Custom (Personalizado) selecionado e, depois, digite o endereço IP do sistema ao qual deseja ser capaz de acessar o console da Web (por exemplo, 192.0.2.1).

5. Escolha Salvar.

   Agora seu agente pode aceitar conexões de entrada.

Crie uma fábrica de conexão em grupo JMS para o produtor da mensagem usando o endpoint do seu agente e, em seguida, chame o método createConnection contra a fábrica.

// Create a connection factory.
final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);

// Pass the sign-in credentials.
connectionFactory.setUserName(activeMqUsername);
connectionFactory.setPassword(activeMqPassword);

// Create a pooled connection factory.
final PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
pooledConnectionFactory.setConnectionFactory(connectionFactory);
pooledConnectionFactory.setMaxConnections(10);

// Establish a connection for the producer.
final Connection producerConnection = pooledConnectionFactory.createConnection();
producerConnection.start(); 

// Close all connections in the pool.
pooledConnectionFactory.clear();

Crie uma sessão, uma fila chamada MyQueue e um produtor de mensagens.

// Create a session.
final Session producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// Create a queue named "MyQueue".
final Destination producerDestination = producerSession.createQueue("MyQueue");

// Create a producer from the session to the queue.
final MessageProducer producer = producerSession.createProducer(producerDestination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

Crie a string da mensagem "Hello from Amazon MQ!" e, em seguida, envie a mensagem.

// Create a message.
final String text = "Hello from Amazon MQ!";
TextMessage producerMessage = producerSession.createTextMessage(text);

// Send the message.
producer.send(producerMessage);
System.out.println("Message sent.");

Limpe o produtor.

producer.close();
producerSession.close();
producerConnection.close();

Crie uma fábrica de conexão JMS para o produtor da mensagem usando o endpoint do seu agente e, em seguida, chame o método createConnection contra a fábrica.

// Create a connection factory.
final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(wireLevelEndpoint);

// Pass the sign-in credentials.
connectionFactory.setUserName(activeMqUsername);
connectionFactory.setPassword(activeMqPassword);

// Establish a connection for the consumer.
final Connection consumerConnection = connectionFactory.createConnection();
consumerConnection.start();

Crie uma sessão, uma fila chamada MyQueue e um consumidor de mensagens.

// Create a session.
final Session consumerSession = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);

// Create a queue named "MyQueue".
final Destination consumerDestination = consumerSession.createQueue("MyQueue");

// Create a message consumer from the session to the queue.
final MessageConsumer consumer = consumerSession.createConsumer(consumerDestination);

Comece a aguardar mensagens e receba a mensagem quando ela chegar.

// Begin to wait for messages.
final Message consumerMessage = consumer.receive(1000);

// Receive the message when it arrives.
final TextMessage consumerTextMessage = (TextMessage) consumerMessage;
System.out.println("Message received: " + consumerTextMessage.getText());

Feche o consumidor, a sessão e a conexão.

consumer.close();
consumerSession.close();
consumerConnection.close();