{scrollbar}

package com.sample.connector;

import java.util.List;
import javax.resource.ResourceException;

/**
 * An interface allowing Events to be Handled.  Message-driven Beans implement
 * this interface, in order to receive inbound-events from our EIS via the JCA adapter.
 */
public interface EventListener {

    /**
     * Method to be called when a Event is handled.
     *
     * @param eventName the name of the event
     * @param paramList the parameters sent to the event
     *
     * @throws ResourceException if an error occurs
     */
    void handleEvent(String eventName, List paramList) throws ResourceException;
}

/*
 * EventActivationSpec.java
 */

package com.sample.connector;

import java.io.Serializable;
import javax.resource.spi.ActivationSpec;
import javax.resource.spi.InvalidPropertyException;
import javax.resource.spi.ResourceAdapter;

/**
 * Implementation of the <code>ActivationSpec</code> interface, which allows EIS Events
 * to be exposed to message-drive beans.  This <code>ActivationSpec</code> is used to
 * support inbound connection from our EIS to a message-driven bean.  This will open
 * an EIS connection and use its event mechanism provided by the EIS-specific connection
 * class.  The connection to the EIS will be held open while the application containing
 * the message-driven bean is available.
 */
public class EventActivationSpec implements ActivationSpec, Serializable  {

    private ResourceAdapter resourceAdapter;     private String serverName;
    private Integer portNumber;
    private String userName;
    private String password;
    private String eventPatterns;//A comma-delimeted string of patterns

    /**
     * Creates a new instance of the EventActivationSpec class.
     */
    public EventActivationSpec() {
    }

    /**
     * No validation is performed
     */
    public void validate() throws InvalidPropertyException {
    }

    //javadoc inherited
    public ResourceAdapter getResourceAdapter() {
        return resourceAdapter;
    }

    //javadoc inherited
    public void setResourceAdapter(ResourceAdapter resourceAdapter) {
        this.resourceAdapter = resourceAdapter;
    }     /**
     * Getter method for the ServerName attribute.  This allows the server name
     * to be defined against a Connection pool
     *
     * @return a <code>String</code> containing the server name value
     */
    public String getServerName() {
        return serverName;
    }

    /**
     * Setter method for the ServerName attribute.  This allows the server name to be
     * defined against a connection pool/.
     *
     * @param serverName the <code>String</code> that will be defined against this attribute
     */
    public void setServerName(String serverName) {
        this.serverName = serverName;
    }

    /**
     * Getter method for the PortNumber attribute.  This allows the port number
     * to be defined against a Connection pool
     *
     * @return a <code>Integer</code> containing the server port value
     */
    public Integer getPortNumber() {
        return portNumber;
    }     /**
     * Setter method for the PortNumber attribute.  This allows the server port to be
     * defined against a connection pool/.
     *
     * @param portNumber the <code>Integer</code> that will be defined against this attribute
     */
    public void setPortNumber(Integer portNumber) {
        this.portNumber = portNumber;
    }

    /**
     * Getter method for the UserName attribute.  This allows the user name
     * to be defined against a Connection pool
     *
     * @return a <code>String</code> containing the user name value
     */
    public String getUserName() {
        return userName;
    }

    /**
     * Setter method for the UserName attribute.  This allows the user name to be
     * defined against a connection pool/.
     *
     * @param userName the <code>String</code> that will be defined against this attribute
     */
    public void setUserName(String userName) {
        this.userName = userName;
    }
     /**
     * Getter method for the Password attribute.  This allows the password
     * to be defined against a Connection pool
     *
     * @return a <code>String</code> containing the password value
     */
    public String getPassword() {
        return password;
    }

    /**
     * Setter method for the Password attribute.  This allows the password to be
     * defined against a connection pool/.
     *
     * @param password the <code>String</code> that will be defined against this attribute
     */
    public void setPassword(String password) {
        this.password = password;
    }

    /**
     * Returns the event patterns that will be used when subscribing to Events.  This string can contain
     * comma-delimited value, in order to subscribe to multiple Events.
     *
     * @return a <code>String</code> containing the event patterns that will be subscribed
     */
    public String getEventPatterns() {
        return eventPatterns;
    }

    /**
     * Defines the event patterns that will be subscribed to by the message-driven beans.  The value can
     * contain comma-delimited patterns, such that multiple events can be subscribed to in the single bean.
     *
     * @param eventPatterns a <code>String</code> containing the single pattern or comma-delimited patterns
     */
    public void setEventPatterns(String eventPatterns) {
        this.eventPatterns = eventPatterns;
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<connector xmlns="http://java.sun.com/xml/ns/j2ee"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/connector_1_5.xsd"
    version="1.5">
    <display-name>EIS Connector</display-name>
    <vendor-name>My Component</vendor-name>
    <eis-type>My Remote Server</eis-type>
    <resourceadapter-version>1.0</resourceadapter-version>
    <resourceadapter>
        <resourceadapter-class>com.sample.connector.MyResourceAdapter</resourceadapter-class>
           <!-- snip -->
        <inbound-resourceadapter>
            <messageadapter>
                <messagelistener>
                    <messagelistener-type>com.sample.connector.EventListener</messagelistener-type>
                    <activationspec>
                        <activationspec-class>com.sample.connector.EventActivationSpec</activationspec-class>
                        <required-config-property>
                            <config-property-name>ServerName</config-property-name>
                        </required-config-property>
                        <required-config-property>
                            <config-property-name>PortNumber</config-property-name>
                        </required-config-property>
                        <required-config-property>
                            <config-property-name>UserName</config-property-name>
                        </required-config-property>
                        <required-config-property>
                            <config-property-name>Password</config-property-name>
                        </required-config-property>
                        <required-config-property>
                            <config-property-name>EventPatterns</config-property-name>
                        </required-config-property>
                    </activationspec>
                </messagelistener>
        </inbound-resourceadapter>
        <security-permission>
            <description>Permissions allowed to the EIS Connector</description>
            <security-permission-spec/>
        </security-permission>
    </resourceadapter>
</connector>

public void endpointActivation(MessageEndpointFactory endpointFactory, ActivationSpec spec) throws ResourceException

<?xml version="1.0" encoding="UTF-8"?>
<connector xmlns="http://geronimo.apache.org/xml/ns/j2ee/connector-1.2">
  <dep:environment xmlns:dep="http://geronimo.apache.org/xml/ns/deployment-1.2">
    <dep:moduleId>
      <dep:groupId>com.sample</dep:groupId>
      <dep:artifactId>myConnector</dep:artifactId>
      <dep:version>1.0</dep:version>
      <dep:type>rar</dep:type>
    </dep:moduleId>
    <dep:dependencies/>
    <dep:hidden-classes/>
    <dep:non-overridable-classes/>
  </dep:environment>
  <resourceadapter>
    <resourceadapter-instance>
      <resourceadapter-name>MyInboundEvents</resourceadapter-name>
      <workmanager>
        <gbean-link>DefaultWorkManager</gbean-link>
      </workmanager>
    </resourceadapter-instance>
  </resourceadapter>
</connector>

package com.sample.eventDemo.message;

import com.sample.connector.EventListener;
import java.util.List;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.resource.ResourceException;

/**
 * Message-driven Bean, listening for Events
 */
@MessageDriven(
    name="EventBean",
    messageListenerInterface=EventListener.class,
    activationConfig={
        @ActivationConfigProperty(propertyName="ServerName",propertyValue="fozzie"),
        @ActivationConfigProperty(propertyName="PortNumber",propertyValue="40100"),
        @ActivationConfigProperty(propertyName="UserName",propertyValue="user"),
        @ActivationConfigProperty(propertyName="Password",propertyValue="pwd"),
        @ActivationConfigProperty(propertyName="EventPatterns",propertyValue="myPattern")
    }
)
public class EventBean implements EventListener {

    /**
     * Method that will be called by the inbound Event handler
     */
    public void handleEvent(String eventName, List paramList) throws ResourceException {
        System.out.println("In MDB: " + eventName + " with params " + paramList.toString());
    }
 }

<?xml version="1.0" encoding="UTF-8"?>
<openejb-jar
        xmlns="http://www.openejb.org/xml/ns/openejb-jar-2.1"
        xmlns:naming="http://geronimo.apache.org/xml/ns/naming-1.1"
        xmlns:security="http://geronimo.apache.org/xml/ns/security-1.1"
        xmlns:sys="http://geronimo.apache.org/xml/ns/deployment-1.2">
    <sys:environment>
        <sys:moduleId>
            <sys:groupId>com.sample.connectorDemo</sys:groupId>
            <sys:artifactId>SampleEventHandler</sys:artifactId>
            <sys:version>1.1</sys:version>
            <sys:type>car</sys:type>
        </sys:moduleId>
        <sys:dependencies>
            <sys:dependency>
                <sys:groupId>com.sample</sys:groupId>
                <sys:artifactId>myConnector</sys:artifactId>
                <sys:version>1.0</sys:version>
                <sys:type>rar</sys:type>
            </sys:dependency>
        </sys:dependencies>
        <sys:hidden-classes/>
        <sys:non-overridable-classes/>
    </sys:environment>
    <enterprise-beans>
        <message-driven>
            <ejb-name>EventBean</ejb-name>
            <resource-adapter>
                <resource-link>MyInboundEvents</resource-link>
            </resource-adapter>
        </message-driven>
    </enterprise-beans>
</openejb-jar>