홈
제품
Red Hat Enterprise MRG
3
Messaging Programming Reference
Chapter 20. Using the qpid-java AMQP 0-10 client

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

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

20.1. A Simple Messaging Program in Java JMS
링크 복사

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();
    }
	}
}

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"));

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

Context context = new InitialContext(properties);

Copy to Clipboard

Toggle word wrap

Creates the JNDI initial context.

ConnectionFactory connectionFactory
          = (ConnectionFactory) context.lookup("qpidConnectionfactory");

ConnectionFactory connectionFactory
          = (ConnectionFactory) context.lookup("qpidConnectionfactory");

Copy to Clipboard

Toggle word wrap

Creates a JMS connection factory for Qpid.

Connection connection = connectionFactory.createConnection();

Connection connection = connectionFactory.createConnection();

Copy to Clipboard

Toggle word wrap

Creates a JMS connection.

connection.start();

connection.start();

Copy to Clipboard

Toggle word wrap

Activates the connection.

Session session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

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");

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

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

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();

message = (TextMessage)messageConsumer.receive();

Copy to Clipboard

Toggle word wrap

Reads the next available message.

connection.close();

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();

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

 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

맨 위로 이동

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

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

20.1. A Simple Messaging Program in Java JMS
링크 복사

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

이 콘텐츠는 선택한 언어로 제공되지 않습니다.

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

20.1. A Simple Messaging Program in Java JMS링크 복사링크가 클립보드에 복사되었습니다!

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links

20.1. A Simple Messaging Program in Java JMS
링크 복사