1 45 package org.exolab.jms.net.vm; 46 47 import java.security.Principal ; 48 import java.util.Iterator ; 49 import java.util.List ; 50 51 import org.exolab.jms.net.connector.Authenticator; 52 import org.exolab.jms.net.connector.ConnectionFactory; 53 import org.exolab.jms.net.connector.ConnectionManager; 54 import org.exolab.jms.net.connector.ConnectionRequestInfo; 55 import org.exolab.jms.net.connector.ManagedConnection; 56 import org.exolab.jms.net.connector.ManagedConnectionAcceptor; 57 import org.exolab.jms.net.connector.ManagedConnectionFactory; 58 import org.exolab.jms.net.connector.ResourceException; 59 import org.exolab.jms.net.connector.URIRequestInfo; 60 import org.exolab.jms.net.uri.URI; 61 62 63 70 public class VMManagedConnectionFactory implements ManagedConnectionFactory { 71 72 79 public ConnectionFactory createConnectionFactory(ConnectionManager manager) 80 throws ResourceException { 81 return new VMConnectionFactory(this, manager); 82 } 83 84 92 public ManagedConnection createManagedConnection(Principal principal, 93 ConnectionRequestInfo info) 94 throws ResourceException { 95 if (!(info instanceof URIRequestInfo)) { 96 throw new ResourceException("Argument 'info' must be of type " 97 + URIRequestInfo.class.getName()); 98 } 99 100 return new VMManagedConnection(principal, (URIRequestInfo) info); 101 } 102 103 111 public ManagedConnectionAcceptor createManagedConnectionAcceptor( 112 Authenticator authenticator, ConnectionRequestInfo info) 113 throws ResourceException { 114 if (!(info instanceof URIRequestInfo)) { 115 throw new ResourceException("Argument 'info' must be of type " 116 + URIRequestInfo.class.getName()); 117 } 118 return new VMManagedConnectionAcceptor(authenticator, 119 (URIRequestInfo) info); 120 } 121 122 132 public ManagedConnection matchManagedConnections(List connections, 133 Principal principal, 134 ConnectionRequestInfo info) 135 throws ResourceException { 136 ManagedConnection result = null; 137 138 if (info instanceof URIRequestInfo) { 139 URIRequestInfo requestInfo = (URIRequestInfo) info; 140 URI uri = requestInfo.getURI(); 141 Iterator iterator = connections.iterator(); 142 while (iterator.hasNext()) { 143 VMManagedConnection connection = 144 (VMManagedConnection) iterator.next(); 145 if (connection.hasPrincipal(principal) && 146 uri.equals(connection.getRemoteURI())) { 147 result = connection; 148 break; 149 } 150 } 151 } 152 return result; 153 } 154 155 165 public ManagedConnectionAcceptor matchManagedConnectionAcceptors( 166 List acceptors, ConnectionRequestInfo info) 167 throws ResourceException { 168 ManagedConnectionAcceptor result = null; 169 170 if (info instanceof URIRequestInfo) { 171 URIRequestInfo requestInfo = (URIRequestInfo) info; 172 URI uri = requestInfo.getURI(); 173 Iterator iterator = acceptors.iterator(); 174 while (iterator.hasNext()) { 175 VMManagedConnectionAcceptor acceptor = 176 (VMManagedConnectionAcceptor) iterator.next(); 177 if (uri.equals(acceptor.getURI())) { 178 result = acceptor; 179 break; 180 } 181 } 182 } 183 return result; 184 } 185 186 } 187 | Popular Tags |