Red Hat Summit Red Hat Summit지원콘솔개발자평가판 시작연락처

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

2.3. Create a Consumer Client

Overview
링크 복사

This section describes how to create a consumer client of the notification broker. The consumer client subscribes to a particular topic and creates a callback service, which is capable of receiving messages directly from the broker.

Sample consumer client code
링크 복사

Example 2.2, “Consumer Client Code” shows the code for a sample consumer client that subscribes to messages published on the MyTopic topic.

Example 2.2. Consumer Client Code

// Java
package org.jboss.fuse.example.wsn.consumer.client;

import javax.xml.bind.JAXBElement;
import javax.xml.namespace.QName;

import org.w3c.dom.Element;

import org.apache.cxf.wsn.client.Consumer;
import org.apache.cxf.wsn.client.NotificationBroker;
import org.apache.cxf.wsn.client.Subscription;
import org.oasis_open.docs.wsn.b_2.NotificationMessageHolderType;

/**
 * 
 */
public final class Client {
    private Client() {
        //not constructed
    }

    /**
     * @param args
     */
    public static void main(String[] args) throws Exception {
        String wsnPort = "8182";
        if (args.length > 0) {
            wsnPort = args[0];
        }
        
        // Start a consumer that will listen for notification messages
        // We'll just print the text content out for now.
        Consumer consumer = new Consumer(new Consumer.Callback() {
            public void notify(NotificationMessageHolderType message) {
                Object o = message.getMessage().getAny();
                System.out.println(message.getMessage().getAny());
                if (o instanceof Element) {
                    System.out.println(((Element)o).getTextContent());
                }
            }
        }, "http://localhost:9001/MyConsumer");
        
        
        // Create a subscription for a Topic on the broker
        NotificationBroker notificationBroker 
            = new NotificationBroker("http://localhost:" + wsnPort + "/wsn/NotificationBroker");
        Subscription subscription = notificationBroker.subscribe(consumer, "MyTopic");


        // Just sleep for a bit to pick up some incoming messages
        Thread.sleep(60000);
        
        // Cleanup and exit
        subscription.unsubscribe();
        consumer.stop();
        System.exit(0);
    }

}
Copy to Clipboard Toggle word wrap

Creating a consumer callback object
링크 복사

In order to receive notification messages from the notification broker, you must create a consumer callback object to receive the messages. The consumer callback object is in fact a Web service which is embedded in your client. The easiest way to create the consumer callback is to use the org.apache.cxf.wsn.client.Consumer class from the simplified client API, which enables you to define a callback as follows: 
        // Start a consumer that will listen for notification messages
        // We'll just print the text content out for now.
        Consumer consumer = new Consumer(new Consumer.Callback() {
            public void notify(NotificationMessageHolderType message) {
                Object o = message.getMessage().getAny();
                System.out.println(message.getMessage().getAny());
                if (o instanceof Element) {
                    System.out.println(((Element)o).getTextContent());
                }
            }
        }, "http://localhost:9001/MyConsumer");
Copy to Clipboard Toggle word wrap
The first argument to the Consumer constructor is a reference to the consumer callback object, which is defined inline. The second argument specifies the URL of the consumer callback endpoint, which can receive messages from the notification broker.

Subscribing to a topic
링크 복사

To start receiving messages, you must subscribe the consumer to a topic in the notification broker. To create a subscription, invoke the following subscribe method on the NotificationBroker proxy object: 
Subscription subscribe(Referencable consumer, String topic)
Copy to Clipboard Toggle word wrap
The first argument is a reference to a Consumer object (which is capable of returning a WS-Addressing endpoint reference to the consumer callback through the Referencable.getEpr() method). The second argument is the name of the topic you want to subscribe to.
The return value is a reference to a Subscription object, which you can use to manage the subscription (for example, pause, resume, or unsubscribe).

Threading in the consumer client
링크 복사

Because the consumer client has an embedded Web service (the consumer callback object), which automatically starts in a background thread, it is necessary to manage threading in this sample client. In particular, after creating the subscription, you need to put the main thread to sleep (by calling Thread.sleep(60000)), so that the thread context can switch to the background thread, where the callback Web service is running. This makes it possible for the consumer callback to receive some messages.

Steps to create a consumer client
링크 복사

Perform the following steps to create a consumer client:
  1. Use the archetype:generate goal to invoke the servicemix-cxf-code-first-osgi-bundle archetype. Under the wsn directory, invoke the Maven archetype as follows: 
    mvn archetype:generate \
  -DarchetypeGroupId=org.apache.servicemix.tooling \
  -DarchetypeArtifactId=servicemix-cxf-code-first-osgi-bundle \
  -DarchetypeVersion=2013.01.0.redhat-610379 \
  -DgroupId=org.jboss.fuse.example \
  -DartifactId=wsn-consumer \
  -Dversion=1.0-SNAPSHOT \
  -Dpackage=org.jboss.fuse.example.wsn.consumer
    Copy to Clipboard Toggle word wrap
    Note
    The backslash characters at the end of each line are effective as line-continuation characters on UNIX and LINUX platforms. If you are entering the command on a Windows platform, however, you must enter the entire command on a single line.
    You will be prompted to confirm the project settings, with a message similar to this one: 
    Confirm properties configuration:
groupId: org.jboss.fuse.example
artifactId: wsn-consumer
version: 1.0-SNAPSHOT
package: org.jboss.fuse.example.wsn.consumer
 Y: :
    Copy to Clipboard Toggle word wrap
    Type Return to accept the settings and generate the project. When the command finishes, you should find a new Maven project in the wsn/wsn-consumer directory.
  2. Some of the generated project files are not needed for this tutorial. Under the wsn/wsn-consumer directory, delete the following files and directories: 
    src/main/resources/META-INF/spring/beans.xml
src/main/java/org/jboss/fuse/example/wsn/consumer/Person.java
src/main/java/org/jboss/fuse/example/wsn/consumer/PersonImpl.java
src/main/java/org/jboss/fuse/example/wsn/consumer/UnknownPersonFault.java
src/main/java/org/jboss/fuse/example/wsn/consumer/types
    Copy to Clipboard Toggle word wrap
  3. Edit the pom.xml file in the wsn-consumer directory, and add the following dependencies, as required by the consumer client: 
    <?xml version="1.0" encoding="UTF-8"?>
<project ...>
    ...
    <dependencies>
        ...
        <!-- Needed for HTTP callback endpoint -->
        <dependency>
            <groupId>org.apache.cxf</groupId>
            <artifactId>cxf-rt-transports-http-jetty</artifactId>
            <version>2.7.0.redhat-610379</version>
        </dependency>

        <!-- Needed for WS-Notification -->
        <dependency>
            <groupId>org.apache.cxf.services.wsn</groupId>
            <artifactId>cxf-services-wsn-api</artifactId>
            <version>2.7.0.redhat-610379</version>
        </dependency>
    </dependencies>
    ...
</project>
    Copy to Clipboard Toggle word wrap
  4. Edit the Client.java file in the wsn-consumer/src/main/java/org/jboss/fuse/example/wsn/consumer/client/ directory, remove the existing content, and replace it with the code from Example 2.2, “Consumer Client Code”.

Test the consumer client
링크 복사

Test the consumer client as follows:
  1. If the JBoss A-MQ container is not already running (with the notification broker installed), start it up now: 
    ./amq
    Copy to Clipboard Toggle word wrap
  2. Run the publisher client at the command line. Open a new command prompt, and enter the following commands: 
    cd wsn/wsn-publisher
mvn -Pclient
    Copy to Clipboard Toggle word wrap
    In the command window, you should see some output like the following: 
    ...
INFO: Creating Service {http://cxf.apache.org/wsn/jaxws}NotificationBrokerService
from WSDL: jar:file:/Users/fbolton/.m2/repository/org/apache/cxf/services/wsn/
cxf-services-wsn-api/2.6.0.redhat-60024/cxf-services-wsn-api-2.6.0.redhat-60024.jar
!/org/apache/cxf/wsn/wsdl/wsn.wsdl
    Copy to Clipboard Toggle word wrap
    You now have approximately two minutes before the publisher client times out.
  3. Run the consumer client at the command line. Open a new command prompt and enter the following commands: 
    cd wsn/wsn-consumer
mvn -Pclient
    Copy to Clipboard Toggle word wrap
    In the command window, you should see some output like the following: 
    ...
Jun 25, 2013 4:13:47 PM org.apache.cxf.service.factory.ReflectionServiceFactoryBean
buildServiceFromWSDL
INFO: Creating Service {http://cxf.apache.org/wsn/jaxws}PausableSubscriptionManagerService
from WSDL: jar:file:/Users/fbolton/.m2/repository/org/apache/cxf/services/wsn
/cxf-services-wsn-api/2.6.0.redhat-60024/cxf-services-wsn-api-2.6.0.redhat-60024.jar
!/org/apache/cxf/wsn/wsdl/wsn.wsdl
[ns8:foo: null]
Hello World!
...
    Copy to Clipboard Toggle word wrap
  4. To inspect the state of the notification broker, you can connect to the JMX port of the ActiveMQ broker. Start up a JMX console by entering the following command at the command line: 
    jconsole
    Copy to Clipboard Toggle word wrap
    In the JConsole: New Connection dialog, select Remote Process and enter the following URL in the accompanying text field: 
    service:jmx:rmi:///jndi/rmi://localhost:1099/karaf-root
    Copy to Clipboard Toggle word wrap
    In the Username and Password fields, enter one of the user credentials you created at the start of this tutorial. When you are connected to the JMX port, you can inspect the state of the broker by clicking on the MBeans tab and drilling down the object tree in the JConsole.
맨 위로 이동
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

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

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

Theme

© 2025 Red Hat