| Methods Summary |
|---|
| public void | endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.resource.spi.ActivationSpec spec)
JmsActivation activation = new JmsActivation(this, endpointFactory, (JmsActivationSpec) spec);
activations.put(spec, activation);
activation.start();
|
| public void | endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory, javax.resource.spi.ActivationSpec spec)
JmsActivation activation = (JmsActivation) activations.remove(spec);
if (activation != null)
activation.stop();
|
| public javax.resource.spi.work.WorkManager | getWorkManager()Get the work manager
return ctx.getWorkManager();
|
| public javax.transaction.xa.XAResource[] | getXAResources(javax.resource.spi.ActivationSpec[] specs)
// TODO getXAResources
return null;
|
| public void | start(javax.resource.spi.BootstrapContext ctx)
this.ctx = ctx;
|
| public void | stop()
for (Iterator i = activations.entrySet().iterator(); i.hasNext();)
{
Map.Entry entry = (Map.Entry) i.next();
try
{
JmsActivation activation = (JmsActivation) entry.getValue();
if (activation != null)
activation.stop();
}
catch (Exception ignored)
{
log.debug("Ignored", ignored);
}
i.remove();
}
|
