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).

Sobre o MyBrokerpágina, na seção Conexões, anote os endereços e portas do console web URL 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 EC2 Painel é 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 Editar regras de entrada, adicione uma regra para cada terminal URL ou endpoint que você deseja que seja acessível ao público (o exemplo a seguir mostra como fazer isso em um console web do broker).

1. Escolha Add Rule.

2. Em Tipo, selecione Personalizado TCP.

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ões em JMS pool para o produtor de mensagens usando o endpoint do seu corretor e, em seguida, chame o createConnection método na 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 JMS conexões para o produtor de mensagens usando o endpoint do seu corretor e, em seguida, chame o createConnection método na 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();