| Methods Summary |
|---|
| private com.sun.enterprise.jbi.serviceengine.util.soap.EndpointMetaData | createEndpointMetaData()
EndpointMetaData emd = new EndpointMetaData(wsdlLocation, service, endpointName);
emd.resolve();
return emd;
|
| private com.sun.enterprise.jbi.serviceengine.util.soap.EndpointMetaData | getEndpointMetaData()Get the EndpointMetaData from the cache if running in production clientCache.
Otherwise, return a new EndpointMetaData.
String clientCache = System.getProperty(JBIConstants.CLIENT_CACHE);
if("false".equalsIgnoreCase(clientCache)) {
return createEndpointMetaData();
} else {
String key = wsdlLocation.toString();
EndpointMetaData emd = emdCache.get(key);
if(emd == null) {
emd = createEndpointMetaData();
emdCache.put(key, emd);
}
return emd;
}
|
| public void | initialize()
try {
DeliveryChannel channel =
JavaEEServiceEngineContext.getInstance(). getDeliveryChannel();
String key = DescriptorEndpointInfo.getDEIKey(service, endpointName);
DescriptorEndpointInfo dei = EndpointRegistry.getInstance().getJBIEndpts().get(key);
QName service = (dei == null)? this.service:dei.getServiceName();
String endpointName = (dei == null)? this.endpointName:dei.getEndpointName();
// Create MessageExchange
MessageExchangeFactory factory =
channel.createExchangeFactoryForService(service);
me = oneWay ? factory.createInOnlyExchange() : factory.createInOutExchange();
me.setService(service);
ComponentContext context = JavaEEServiceEngineContext.getInstance().getJBIContext();
me.setEndpoint(context.getEndpoint(service, endpointName));
me.setOperation(operation);
meTransport = MessageExchangeTransportFactory.getHandler(me);
} catch (Exception ex) {
ex.printStackTrace();
throw new RuntimeException(ex);
}
|
| public com.sun.enterprise.jbi.serviceengine.comm.UnWrappedMessage | receiveResponse()
return meTransport.receive(getEndpointMetaData());
|
| public void | sendRequest(com.sun.xml.ws.api.message.Message abstractMessage)
meTransport.send(abstractMessage, getEndpointMetaData());
|
| public void | sendStatus()
if(me.getStatus().equals(ExchangeStatus.ACTIVE)) {
meTransport.sendStatus(ExchangeStatus.DONE);
}
|
| public void | setOneWay(boolean oneWay)
this.oneWay = oneWay;
|
