1 29 30 package com.caucho.jms.amq; 31 32 import com.caucho.server.connection.Connection; 33 import com.caucho.server.port.Protocol; 34 import com.caucho.server.port.ServerRequest; 35 36 39 public class AmqProtocol extends Protocol { 40 private ClassLoader _loader = Thread.currentThread().getContextClassLoader(); 41 42 45 public String getProtocolName() 46 { 47 return "svn"; 48 } 49 50 53 public ServerRequest createRequest(Connection conn) 54 { 55 return new AmqRequest(conn, _loader); 56 } 57 } 58 | Popular Tags |