org.xmlBlaster.j2ee.k2
Class BlasterConnectionImpl

java.lang.Object
  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