xmlBlaster 2.1.0 API

org.xmlBlaster.j2ee.k2
Class BlasterConnectionImpl

java.lang.Object
  extended by org.xmlBlaster.j2ee.k2.BlasterConnectionImpl
All Implemented Interfaces:
BlasterConnection

public class BlasterConnectionImpl
extends java.lang.Object
implements BlasterConnection

An implementing handler to a physical connection. One or more handles may be sychronized over a single physical connection. Created: Sat Jan 27 20:34:17 2001


Field Summary
private  boolean closed
           
private  BlasterManagedConnection mc
           
 
Constructor Summary
BlasterConnectionImpl(BlasterManagedConnection mc)
           
 
Method Summary
private  void checkSanity()
           
(package private)  void cleanup()
           
 void close()
          Close the connection.
(package private)  void destroy()
           
 EraseReturnQos[] erase(java.lang.String xmlKey, java.lang.String qos)
          Erase message(s), I think
 MsgUnit[] get(java.lang.String xmlKey, java.lang.String qos)
          Fetch a message from server
 Global getGlobal()
          Get Global from connection
(package private)  void open()
           
 PublishReturnQos publish(MsgUnit msgUnit)
          Publish one message
 PublishReturnQos[] publishArr(MsgUnit[] msgUnitArr)
          Publish one or more message
(package private)  void setBlasterManagedConnection(BlasterManagedConnection mc)
          Set an mc.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

mc

private BlasterManagedConnection mc

closed

private boolean closed
Constructor Detail

BlasterConnectionImpl

public BlasterConnectionImpl(BlasterManagedConnection mc)
Method Detail

getGlobal

public Global getGlobal()
                 throws XmlBlasterException
Get Global from connection

Specified by:
getGlobal in interface BlasterConnection
Throws:
XmlBlasterException

get

public MsgUnit[] get(java.lang.String xmlKey,
                     java.lang.String qos)
              throws XmlBlasterException
Fetch a message from server

Specified by:
get in interface BlasterConnection
Throws:
XmlBlasterException

publish

public PublishReturnQos publish(MsgUnit msgUnit)
                         throws XmlBlasterException
Publish one message

Specified by:
publish in interface BlasterConnection
Throws:
XmlBlasterException

publishArr

public PublishReturnQos[] publishArr(MsgUnit[] msgUnitArr)
                              throws XmlBlasterException
Publish one or more message

Specified by:
publishArr in interface BlasterConnection
Throws:
XmlBlasterException

erase

public EraseReturnQos[] erase(java.lang.String xmlKey,
                              java.lang.String qos)
                       throws XmlBlasterException
Erase message(s), I think

Specified by:
erase in interface BlasterConnection
Throws:
XmlBlasterException

close

public void close()
           throws XmlBlasterException
Close the connection. After this the client may not use the connection again, but should get a new from the ConnectionFactory.

Specified by:
close in interface BlasterConnection
Throws:
XmlBlasterException

open

void open()

destroy

void destroy()

cleanup

void cleanup()

setBlasterManagedConnection

void setBlasterManagedConnection(BlasterManagedConnection mc)
Set an mc. This will handle two cases. 1. When an mc want to retain a closed or cleaned upp handle 2. When it is reasociated with a new mc


checkSanity

private void checkSanity()
                  throws XmlBlasterException
Throws:
XmlBlasterException

xmlBlaster 2.1.0 API

Copyright © 1999-2011 The xmlBlaster.org contributers.