Red Hat Summit Red Hat SummitSupportConsoleDéveloppeursCommencer un essaiContact

Ce contenu n'est pas disponible dans la langue sélectionnée.

Chapter 20. Using the qpid-java AMQP 0-10 client

20.1. A Simple Messaging Program in Java JMS
Copier lien

The following program shows how to send and receive a message using the qpid-java client. JMS programs typically use JNDI to obtain connection factory and destination objects which the application needs. In this way the configuration is kept separate from the application code itself.
In this example, we create a JNDI context using a properties file, use the context to lookup a connection factory, create and start a connection, create a session, and lookup a destination from the JNDI context. Then we create a producer and a consumer, send a message with the producer and receive it with the consumer. 
package org.apache.qpid.example.jmsexample.hello;

import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import java.util.Properties;

public class Hello {

    public Hello() {
    }

    public static void main(String[] args) {
    	Hello producer = new Hello();
        producer.runTest();
    }

    private void runTest() {
    	try {
    Properties properties = new Properties();
        properties.load(this.getClass().getResourceAsStream("hello.properties"));  
        Context context = new InitialContext(properties);   
  
        ConnectionFactory connectionFactory
          = (ConnectionFactory) context.lookup("qpidConnectionfactory"); 	
    	Connection connection = connectionFactory.createConnection();
    	connection.start(); 

	  	Session session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
	  	Destination destination = (Destination) context.lookup("topicExchange"); 

	  	MessageProducer messageProducer = session.createProducer(destination);  
	  	MessageConsumer messageConsumer = session.createConsumer(destination);  

	  	TextMessage message = session.createTextMessage("Hello world!");
	  messageProducer.send(message);

	  message = (TextMessage)messageConsumer.receive();    
	  System.out.println(message.getText());

	  connection.close();  
	  context.close();   
    }
    catch (Exception exp) {
    	exp.printStackTrace();
    }
	}
}
Copy to Clipboard Toggle word wrap
Explanation

Here is an explanation of the program code: 

properties.load(this.getClass().getResourceAsStream("hello.properties"));
Copy to Clipboard Toggle word wrap
Loads the JNDI properties file, which specifies connection properties, queues, topics, and addressing options. 
Context context = new InitialContext(properties);
Copy to Clipboard Toggle word wrap
Creates the JNDI initial context. 
ConnectionFactory connectionFactory
          = (ConnectionFactory) context.lookup("qpidConnectionfactory");
Copy to Clipboard Toggle word wrap
Creates a JMS connection factory for Qpid. 
Connection connection = connectionFactory.createConnection();
Copy to Clipboard Toggle word wrap
Creates a JMS connection. 
connection.start();
Copy to Clipboard Toggle word wrap
Activates the connection. 
Session session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
Copy to Clipboard Toggle word wrap
Creates a session. This session is not transactional (transactions='false'), and messages are automatically acknowledged. 
Destination destination = (Destination) context.lookup("topicExchange");
Copy to Clipboard Toggle word wrap
Creates a destination for the topic exchange, so senders and receivers can use it. 
MessageProducer messageProducer = session.createProducer(destination);
Copy to Clipboard Toggle word wrap
Creates a producer that sends messages to the topic exchange. 
MessageConsumer messageConsumer = session.createConsumer(destination);
Copy to Clipboard Toggle word wrap
Creates a consumer that reads messages from the topic exchange. 
message = (TextMessage)messageConsumer.receive();
Copy to Clipboard Toggle word wrap
Reads the next available message. 
connection.close();
Copy to Clipboard Toggle word wrap
Closes the connection, all sessions managed by the connection, and all senders and receivers managed by each session. 
context.close();
Copy to Clipboard Toggle word wrap
Closes the JNDI context.
hello.properties file

The contents of the hello.properties file are shown below. 

 java.naming.factory.initial
	  = org.apache.qpid.jndi.PropertiesFileInitialContextFactory

# connectionfactory.[jndiname] = [ConnectionURL]
connectionfactory.qpidConnectionfactory
   = amqp://guest:guest@clientid/test?brokerlist='tcp://localhost:5672' 
# destination.[jndiname] = [address_string]
destination.topicExchange = amq.topic
Copy to Clipboard Toggle word wrap
Report a bug
Retour au début
Red Hat logoGithubredditYoutubeTwitter

Apprendre

Essayez, achetez et vendez

Communautés

À propos de la documentation Red Hat

Nous aidons les utilisateurs de Red Hat à innover et à atteindre leurs objectifs grâce à nos produits et services avec un contenu auquel ils peuvent faire confiance. Découvrez nos récentes mises à jour.

Rendre l’open source plus inclusif

Red Hat s'engage à remplacer le langage problématique dans notre code, notre documentation et nos propriétés Web. Pour plus de détails, consultez le Blog Red Hat.

À propos de Red Hat

Nous proposons des solutions renforcées qui facilitent le travail des entreprises sur plusieurs plates-formes et environnements, du centre de données central à la périphérie du réseau.

Theme

© 2025 Red Hat