1 /* 2 * Copyright (c) 1998-2006 Caucho Technology -- all rights reserved 3 * 4 * This file is part of Resin(R) Open Source 5 * 6 * Each copy or derived work must preserve the copyright notice and this 7 * notice unmodified. 8 * 9 * Resin Open Source is free software; you can redistribute it and/or modify 10 * it under the terms of the GNU General Public License as published by 11 * the Free Software Foundation; either version 2 of the License, or 12 * (at your option) any later version. 13 * 14 * Resin Open Source is distributed in the hope that it will be useful, 15 * but WITHOUT ANY WARRANTY; without even the implied warranty of 16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE, or any warranty 17 * of NON-INFRINGEMENT. See the GNU General Public License for more 18 * details. 19 * 20 * You should have received a copy of the GNU General Public License 21 * along with Resin Open Source; if not, write to the 22 * Free SoftwareFoundation, Inc. 23 * 59 Temple Place, Suite 330 24 * Boston, MA 02111-1307 USA 25 * 26 * @author Scott Ferguson 27 */ 28 29 package com.caucho.jms.jca; 30 31 import com.caucho.config.BuilderProgram; 32 import com.caucho.config.ConfigException; 33 import com.caucho.log.Log; 34 import com.caucho.util.L10N; 35 36 import javax.resource.spi.UnavailableException; 37 import javax.resource.spi.endpoint.MessageEndpoint; 38 import javax.resource.spi.endpoint.MessageEndpointFactory; 39 import javax.transaction.xa.XAResource; 40 import java.lang.reflect.Method; 41 import java.util.logging.Logger; 42 43 /** 44 * The JMS MessageListener endpoing factory 45 */ 46 public class ListenerEndpointFactory implements MessageEndpointFactory { 47 private static final Logger log = Log.open(ListenerEndpointFactory.class); 48 private static final L10N L = new L10N(ListenerEndpointFactory.class); 49 50 private BuilderProgram _program; 51 52 private ListenerEndpoint _initialEndpoint; 53 54 public void setListener(BuilderProgram program) 55 throws Throwable 56 { 57 _program = program; 58 59 _initialEndpoint = new ListenerEndpoint(); 60 program.configure(_initialEndpoint); 61 } 62 63 /** 64 * Initialization. 65 */ 66 public void init() 67 throws ConfigException 68 { 69 if (_initialEndpoint == null) { 70 throw new ConfigException(L.l("ListenerEndpointFactory needs a <listener>")); 71 } 72 } 73 74 /** 75 * Creates an endpoint with the associated XA resource. 76 */ 77 public MessageEndpoint createEndpoint(XAResource xaResource) 78 throws UnavailableException 79 { 80 try { 81 ListenerEndpoint listener = _initialEndpoint; 82 _initialEndpoint = null; 83 84 if (listener == null) { 85 listener = new ListenerEndpoint(); 86 _program.configure(listener); 87 } 88 89 return listener; 90 } catch (Throwable e) { 91 throw new UnavailableException(e); 92 } 93 } 94 95 /** 96 * Returns true to find out whether message deliveries to the 97 * message endpoint will be transacted. This is only a hint. 98 */ 99 public boolean isDeliveryTransacted(Method method) 100 { 101 return false; 102 } 103 } 104 105