Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * $Id$
   * $URL$
   *
   * ====================================================================
   * Ikasan Enterprise Integration Platform
   *
   * Distributed under the Modified BSD License.
   * Copyright notice: The copyright for this software and a full listing
  * of individual contributors are as shown in the packaged copyright.txt
  * file.
  *
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are met:
  *
  *  - Redistributions of source code must retain the above copyright notice,
  *    this list of conditions and the following disclaimer.
  *
  *  - Redistributions in binary form must reproduce the above copyright notice,
  *    this list of conditions and the following disclaimer in the documentation
  *    and/or other materials provided with the distribution.
  *
  *  - Neither the name of the ORGANIZATION nor the names of its contributors may
  *    be used to endorse or promote products derived from this software without
  *    specific prior written permission.
  *
  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
  * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  * ====================================================================
  */
 package org.ikasan.compatibility.component.endpoint;
 
 
 import  javax.jms.JMSException;
 import  javax.jms.MapMessage;

Manages the event identifier setting/getting for messages to/from i8 JMS pub/sub Ikasan Developmnet Team.
 
 public class ManagedEventJmsIdentifierService implements ManagedEventIdentifierService<String, MapMessage>
 {
    
ikasan 0.8.x event identifer
 
     static String I8_EVENT_ID = String.valueOf("EVENT_ID");

    
ikasan 0.8.x event identifer
 
     static String I7_ENVELOPE_ID = String.valueOf("envelope_id");

    
logger instance
 
     private static Logger logger = Logger.getLogger(ManagedEventJmsIdentifierService.class);
 
     @Override
     public void setEventIdentifier(String identifier, MapMessage mapMessagethrows ManagedEventIdentifierException
     {
         try
         {
             mapMessage.setString(identifier);
         }
         catch(JMSException e)
         {
             throw new ManagedEventIdentifierException(e);
         }
     }
 
     @Override
     public String getEventIdentifier(MapMessage mapMessagethrows ManagedEventIdentifierException
     {
         try
         {
             String eventId = mapMessage.getString();
             if(eventId == null)
             {
                 eventId = mapMessage.getString();
                 if(eventId == null)
                 {
                     // last resort is the JMS identifier
                     eventId = mapMessage.getJMSMessageID();
                 }
             }
 
             return eventId;
         }
         catch(JMSException e)
         {
             throw new ManagedEventIdentifierException(e);
         }
    }
New to GrepCode? Check out our FAQ X