org.backsource.adaptor.jms
Class Bridge

java.lang.Object
  javax.management.NotificationBroadcasterSupport
      org.jboss.system.ServiceMBeanSupport
          org.backsource.jmx.ServiceMBeanSupport
              org.backsource.adaptor.jms.Listener
                  org.backsource.adaptor.jms.Bridge

All Implemented Interfaces:

org.backsource.adaptor.jms.BridgeMBean, java.util.EventListener, org.backsource.adaptor.jms.ListenerMBean, javax.management.MBeanRegistration, javax.jms.MessageListener, javax.management.NotificationBroadcaster, javax.management.NotificationListener, org.jboss.system.Service, org.backsource.jmx.ServiceMBean, org.jboss.system.ServiceMBean

public class Bridge

extends Listener

implements org.backsource.adaptor.jms.BridgeMBean

Simple first cut on non transactional bride.

Version:

$Revision: 1.1.1.1 $

Author:

Peter Antman

Field Summary

Fields inherited from class org.backsource.adaptor.jms.Listener

OBJECT_NAME, server

Fields inherited from class org.jboss.system.ServiceMBeanSupport

log, serviceName

Fields inherited from interface org.jboss.system.ServiceMBean

CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, STARTED, STARTING, states, STOPPED, STOPPING

Constructor Summary

Bridge()

Method Summary

protected javax.jms.BytesMessage	createOutputBytesMessage(javax.jms.Session session, javax.jms.BytesMessage inputMessage) Factory method to create BytesMessage Derived classes could override this method to perform any kind of Message transformation.
protected javax.jms.MapMessage	createOutputMapMessage(javax.jms.Session session, javax.jms.MapMessage inputMessage) Factory method to create MapMessage Derived classes could override this method to perform any kind of Message transformation.
protected javax.jms.Message	createOutputMessage(javax.jms.Session session, javax.jms.Message inputMessage) Factory method to create an output message given an input message.
protected javax.jms.ObjectMessage	createOutputObjectMessage(javax.jms.Session session, javax.jms.ObjectMessage inputMessage) Factory method to create ObjectMessage Derived classes could override this method to perform any kind of Message transformation.
protected javax.jms.StreamMessage	createOutputStreamMessage(javax.jms.Session session, javax.jms.StreamMessage inputMessage) Factory method to create StreamMessage Derived classes could override this method to perform any kind of Message transformation.
protected javax.jms.TextMessage	createOutputTextMessage(javax.jms.Session session, javax.jms.TextMessage inputMessage) Factory method to create TextMessage Derived classes could override this method to perform any kind of Message transformation.
protected MessageProducer	getPublisher()
javax.management.ObjectName	getPublisherMBean()
void	onMessage(javax.jms.Message message)
protected void	processMessageHeaders(javax.jms.Message inputMessage, javax.jms.Message outputMessage) Strategy method to add any headers required on the output message.
void	setPublisherMBean(javax.management.ObjectName publisherMBean)

Methods inherited from class org.backsource.adaptor.jms.Listener

getBroadcaster, getFilter, getObjectName, handleNotification, setBroadcaster, setFilter, startService

Methods inherited from class org.jboss.system.ServiceMBeanSupport

create, createService, destroy, destroyService, getLog, getName, getNextNotificationSequenceNumber, getServer, getServiceName, getState, getStateString, postDeregister, postRegister, preDeregister, preRegister, start, stop, stopService

Methods inherited from class javax.management.NotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.backsource.adaptor.jms.ListenerMBean

getBroadcaster, getFilter, handleNotification, setBroadcaster, setFilter

Methods inherited from interface org.jboss.system.ServiceMBean

getName, getState, getStateString

Methods inherited from interface org.jboss.system.Service

create, destroy, start, stop

Constructor Detail

Bridge

public Bridge()

Method Detail

setPublisherMBean

public void setPublisherMBean(javax.management.ObjectName publisherMBean)

Specified by:

setPublisherMBean in interface org.backsource.adaptor.jms.BridgeMBean

getPublisherMBean

public javax.management.ObjectName getPublisherMBean()

Specified by:

getPublisherMBean in interface org.backsource.adaptor.jms.BridgeMBean

getPublisher

protected MessageProducer getPublisher()
                                throws java.lang.Exception

Throws:

java.lang.Exception

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

Specified by:

onMessage in class Listener

createOutputMessage

protected javax.jms.Message createOutputMessage(javax.jms.Session session,
                                                javax.jms.Message inputMessage)
                                         throws javax.jms.JMSException

Factory method to create an output message given an input message. Derived classes could override this method to perform any kind of Message transformation.

Throws:

javax.jms.JMSException

createOutputObjectMessage

protected javax.jms.ObjectMessage createOutputObjectMessage(javax.jms.Session session,
                                                            javax.jms.ObjectMessage inputMessage)
                                                     throws javax.jms.JMSException

Factory method to create ObjectMessage Derived classes could override this method to perform any kind of Message transformation.

Throws:

javax.jms.JMSException

createOutputTextMessage

protected javax.jms.TextMessage createOutputTextMessage(javax.jms.Session session,
                                                        javax.jms.TextMessage inputMessage)
                                                 throws javax.jms.JMSException

Factory method to create TextMessage Derived classes could override this method to perform any kind of Message transformation.

Throws:

javax.jms.JMSException

createOutputMapMessage

protected javax.jms.MapMessage createOutputMapMessage(javax.jms.Session session,
                                                      javax.jms.MapMessage inputMessage)
                                               throws javax.jms.JMSException

Factory method to create MapMessage Derived classes could override this method to perform any kind of Message transformation.

Throws:

javax.jms.JMSException

createOutputBytesMessage

protected javax.jms.BytesMessage createOutputBytesMessage(javax.jms.Session session,
                                                          javax.jms.BytesMessage inputMessage)
                                                   throws javax.jms.JMSException

Factory method to create BytesMessage Derived classes could override this method to perform any kind of Message transformation.

Throws:

javax.jms.JMSException

createOutputStreamMessage

protected javax.jms.StreamMessage createOutputStreamMessage(javax.jms.Session session,
                                                            javax.jms.StreamMessage inputMessage)
                                                     throws javax.jms.JMSException

Factory method to create StreamMessage Derived classes could override this method to perform any kind of Message transformation.

Throws:

javax.jms.JMSException

processMessageHeaders

protected void processMessageHeaders(javax.jms.Message inputMessage,
                                     javax.jms.Message outputMessage)
                              throws javax.jms.JMSException

Strategy method to add any headers required on the output message. Derived classes could override this method to perform any kind of header processing, such as copying the correlation ID, copying all headers or adding some new custom headers etc.

Throws:

javax.jms.JMSException