jms-1.1

16:37:56.038 INFO  jd.cli.Main - Decompiling jms-1.1.jar
package javax.jms;

public abstract interface BytesMessage
  extends Message
{
  public abstract long getBodyLength()
    throws JMSException;
  
  public abstract boolean readBoolean()
    throws JMSException;
  
  public abstract byte readByte()
    throws JMSException;
  
  public abstract int readUnsignedByte()
    throws JMSException;
  
  public abstract short readShort()
    throws JMSException;
  
  public abstract int readUnsignedShort()
    throws JMSException;
  
  public abstract char readChar()
    throws JMSException;
  
  public abstract int readInt()
    throws JMSException;
  
  public abstract long readLong()
    throws JMSException;
  
  public abstract float readFloat()
    throws JMSException;
  
  public abstract double readDouble()
    throws JMSException;
  
  public abstract String readUTF()
    throws JMSException;
  
  public abstract int readBytes(byte[] paramArrayOfByte)
    throws JMSException;
  
  public abstract int readBytes(byte[] paramArrayOfByte, int paramInt)
    throws JMSException;
  
  public abstract void writeBoolean(boolean paramBoolean)
    throws JMSException;
  
  public abstract void writeByte(byte paramByte)
    throws JMSException;
  
  public abstract void writeShort(short paramShort)
    throws JMSException;
  
  public abstract void writeChar(char paramChar)
    throws JMSException;
  
  public abstract void writeInt(int paramInt)
    throws JMSException;
  
  public abstract void writeLong(long paramLong)
    throws JMSException;
  
  public abstract void writeFloat(float paramFloat)
    throws JMSException;
  
  public abstract void writeDouble(double paramDouble)
    throws JMSException;
  
  public abstract void writeUTF(String paramString)
    throws JMSException;
  
  public abstract void writeBytes(byte[] paramArrayOfByte)
    throws JMSException;
  
  public abstract void writeBytes(byte[] paramArrayOfByte, int paramInt1, int paramInt2)
    throws JMSException;
  
  public abstract void writeObject(Object paramObject)
    throws JMSException;
  
  public abstract void reset()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.BytesMessage
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface Connection
{
  public abstract Session createSession(boolean paramBoolean, int paramInt)
    throws JMSException;
  
  public abstract String getClientID()
    throws JMSException;
  
  public abstract void setClientID(String paramString)
    throws JMSException;
  
  public abstract ConnectionMetaData getMetaData()
    throws JMSException;
  
  public abstract ExceptionListener getExceptionListener()
    throws JMSException;
  
  public abstract void setExceptionListener(ExceptionListener paramExceptionListener)
    throws JMSException;
  
  public abstract void start()
    throws JMSException;
  
  public abstract void stop()
    throws JMSException;
  
  public abstract void close()
    throws JMSException;
  
  public abstract ConnectionConsumer createConnectionConsumer(Destination paramDestination, String paramString, ServerSessionPool paramServerSessionPool, int paramInt)
    throws JMSException;
  
  public abstract ConnectionConsumer createDurableConnectionConsumer(Topic paramTopic, String paramString1, String paramString2, ServerSessionPool paramServerSessionPool, int paramInt)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.Connection
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface ConnectionConsumer
{
  public abstract ServerSessionPool getServerSessionPool()
    throws JMSException;
  
  public abstract void close()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.ConnectionConsumer
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface ConnectionFactory
{
  public abstract Connection createConnection()
    throws JMSException;
  
  public abstract Connection createConnection(String paramString1, String paramString2)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.ConnectionFactory
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

import java.util.Enumeration;

public abstract interface ConnectionMetaData
{
  public abstract String getJMSVersion()
    throws JMSException;
  
  public abstract int getJMSMajorVersion()
    throws JMSException;
  
  public abstract int getJMSMinorVersion()
    throws JMSException;
  
  public abstract String getJMSProviderName()
    throws JMSException;
  
  public abstract String getProviderVersion()
    throws JMSException;
  
  public abstract int getProviderMajorVersion()
    throws JMSException;
  
  public abstract int getProviderMinorVersion()
    throws JMSException;
  
  public abstract Enumeration getJMSXPropertyNames()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.ConnectionMetaData
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface DeliveryMode
{
  public static final int NON_PERSISTENT = 1;
  public static final int PERSISTENT = 2;
}

/* Location:
 * Qualified Name:     javax.jms.DeliveryMode
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface Destination {}

/* Location:
 * Qualified Name:     javax.jms.Destination
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface ExceptionListener
{
  public abstract void onException(JMSException paramJMSException);
}

/* Location:
 * Qualified Name:     javax.jms.ExceptionListener
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class IllegalStateException
  extends JMSException
{
  public IllegalStateException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public IllegalStateException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.IllegalStateException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class InvalidClientIDException
  extends JMSException
{
  public InvalidClientIDException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public InvalidClientIDException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.InvalidClientIDException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class InvalidDestinationException
  extends JMSException
{
  public InvalidDestinationException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public InvalidDestinationException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.InvalidDestinationException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class InvalidSelectorException
  extends JMSException
{
  public InvalidSelectorException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public InvalidSelectorException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.InvalidSelectorException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class JMSException
  extends Exception
{
  private String errorCode;
  private Exception linkedException;
  
  public JMSException(String reason, String errorCode)
  {
    super(reason);
    this.errorCode = errorCode;
    linkedException = null;
  }
  
  public JMSException(String reason)
  {
    super(reason);
    errorCode = null;
    linkedException = null;
  }
  
  public String getErrorCode()
  {
    return errorCode;
  }
  
  public Exception getLinkedException()
  {
    return linkedException;
  }
  
  public synchronized void setLinkedException(Exception ex)
  {
    linkedException = ex;
  }
}

/* Location:
 * Qualified Name:     javax.jms.JMSException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class JMSSecurityException
  extends JMSException
{
  public JMSSecurityException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public JMSSecurityException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.JMSSecurityException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

import java.util.Enumeration;

public abstract interface MapMessage
  extends Message
{
  public abstract boolean getBoolean(String paramString)
    throws JMSException;
  
  public abstract byte getByte(String paramString)
    throws JMSException;
  
  public abstract short getShort(String paramString)
    throws JMSException;
  
  public abstract char getChar(String paramString)
    throws JMSException;
  
  public abstract int getInt(String paramString)
    throws JMSException;
  
  public abstract long getLong(String paramString)
    throws JMSException;
  
  public abstract float getFloat(String paramString)
    throws JMSException;
  
  public abstract double getDouble(String paramString)
    throws JMSException;
  
  public abstract String getString(String paramString)
    throws JMSException;
  
  public abstract byte[] getBytes(String paramString)
    throws JMSException;
  
  public abstract Object getObject(String paramString)
    throws JMSException;
  
  public abstract Enumeration getMapNames()
    throws JMSException;
  
  public abstract void setBoolean(String paramString, boolean paramBoolean)
    throws JMSException;
  
  public abstract void setByte(String paramString, byte paramByte)
    throws JMSException;
  
  public abstract void setShort(String paramString, short paramShort)
    throws JMSException;
  
  public abstract void setChar(String paramString, char paramChar)
    throws JMSException;
  
  public abstract void setInt(String paramString, int paramInt)
    throws JMSException;
  
  public abstract void setLong(String paramString, long paramLong)
    throws JMSException;
  
  public abstract void setFloat(String paramString, float paramFloat)
    throws JMSException;
  
  public abstract void setDouble(String paramString, double paramDouble)
    throws JMSException;
  
  public abstract void setString(String paramString1, String paramString2)
    throws JMSException;
  
  public abstract void setBytes(String paramString, byte[] paramArrayOfByte)
    throws JMSException;
  
  public abstract void setBytes(String paramString, byte[] paramArrayOfByte, int paramInt1, int paramInt2)
    throws JMSException;
  
  public abstract void setObject(String paramString, Object paramObject)
    throws JMSException;
  
  public abstract boolean itemExists(String paramString)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.MapMessage
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

import java.util.Enumeration;

public abstract interface Message
{
  public static final int DEFAULT_DELIVERY_MODE = 2;
  public static final int DEFAULT_PRIORITY = 4;
  public static final long DEFAULT_TIME_TO_LIVE = 0L;
  
  public abstract String getJMSMessageID()
    throws JMSException;
  
  public abstract void setJMSMessageID(String paramString)
    throws JMSException;
  
  public abstract long getJMSTimestamp()
    throws JMSException;
  
  public abstract void setJMSTimestamp(long paramLong)
    throws JMSException;
  
  public abstract byte[] getJMSCorrelationIDAsBytes()
    throws JMSException;
  
  public abstract void setJMSCorrelationIDAsBytes(byte[] paramArrayOfByte)
    throws JMSException;
  
  public abstract void setJMSCorrelationID(String paramString)
    throws JMSException;
  
  public abstract String getJMSCorrelationID()
    throws JMSException;
  
  public abstract Destination getJMSReplyTo()
    throws JMSException;
  
  public abstract void setJMSReplyTo(Destination paramDestination)
    throws JMSException;
  
  public abstract Destination getJMSDestination()
    throws JMSException;
  
  public abstract void setJMSDestination(Destination paramDestination)
    throws JMSException;
  
  public abstract int getJMSDeliveryMode()
    throws JMSException;
  
  public abstract void setJMSDeliveryMode(int paramInt)
    throws JMSException;
  
  public abstract boolean getJMSRedelivered()
    throws JMSException;
  
  public abstract void setJMSRedelivered(boolean paramBoolean)
    throws JMSException;
  
  public abstract String getJMSType()
    throws JMSException;
  
  public abstract void setJMSType(String paramString)
    throws JMSException;
  
  public abstract long getJMSExpiration()
    throws JMSException;
  
  public abstract void setJMSExpiration(long paramLong)
    throws JMSException;
  
  public abstract int getJMSPriority()
    throws JMSException;
  
  public abstract void setJMSPriority(int paramInt)
    throws JMSException;
  
  public abstract void clearProperties()
    throws JMSException;
  
  public abstract boolean propertyExists(String paramString)
    throws JMSException;
  
  public abstract boolean getBooleanProperty(String paramString)
    throws JMSException;
  
  public abstract byte getByteProperty(String paramString)
    throws JMSException;
  
  public abstract short getShortProperty(String paramString)
    throws JMSException;
  
  public abstract int getIntProperty(String paramString)
    throws JMSException;
  
  public abstract long getLongProperty(String paramString)
    throws JMSException;
  
  public abstract float getFloatProperty(String paramString)
    throws JMSException;
  
  public abstract double getDoubleProperty(String paramString)
    throws JMSException;
  
  public abstract String getStringProperty(String paramString)
    throws JMSException;
  
  public abstract Object getObjectProperty(String paramString)
    throws JMSException;
  
  public abstract Enumeration getPropertyNames()
    throws JMSException;
  
  public abstract void setBooleanProperty(String paramString, boolean paramBoolean)
    throws JMSException;
  
  public abstract void setByteProperty(String paramString, byte paramByte)
    throws JMSException;
  
  public abstract void setShortProperty(String paramString, short paramShort)
    throws JMSException;
  
  public abstract void setIntProperty(String paramString, int paramInt)
    throws JMSException;
  
  public abstract void setLongProperty(String paramString, long paramLong)
    throws JMSException;
  
  public abstract void setFloatProperty(String paramString, float paramFloat)
    throws JMSException;
  
  public abstract void setDoubleProperty(String paramString, double paramDouble)
    throws JMSException;
  
  public abstract void setStringProperty(String paramString1, String paramString2)
    throws JMSException;
  
  public abstract void setObjectProperty(String paramString, Object paramObject)
    throws JMSException;
  
  public abstract void acknowledge()
    throws JMSException;
  
  public abstract void clearBody()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.Message
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface MessageConsumer
{
  public abstract String getMessageSelector()
    throws JMSException;
  
  public abstract MessageListener getMessageListener()
    throws JMSException;
  
  public abstract void setMessageListener(MessageListener paramMessageListener)
    throws JMSException;
  
  public abstract Message receive()
    throws JMSException;
  
  public abstract Message receive(long paramLong)
    throws JMSException;
  
  public abstract Message receiveNoWait()
    throws JMSException;
  
  public abstract void close()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.MessageConsumer
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class MessageEOFException
  extends JMSException
{
  public MessageEOFException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public MessageEOFException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.MessageEOFException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class MessageFormatException
  extends JMSException
{
  public MessageFormatException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public MessageFormatException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.MessageFormatException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface MessageListener
{
  public abstract void onMessage(Message paramMessage);
}

/* Location:
 * Qualified Name:     javax.jms.MessageListener
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class MessageNotReadableException
  extends JMSException
{
  public MessageNotReadableException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public MessageNotReadableException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.MessageNotReadableException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class MessageNotWriteableException
  extends JMSException
{
  public MessageNotWriteableException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public MessageNotWriteableException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.MessageNotWriteableException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface MessageProducer
{
  public abstract void setDisableMessageID(boolean paramBoolean)
    throws JMSException;
  
  public abstract boolean getDisableMessageID()
    throws JMSException;
  
  public abstract void setDisableMessageTimestamp(boolean paramBoolean)
    throws JMSException;
  
  public abstract boolean getDisableMessageTimestamp()
    throws JMSException;
  
  public abstract void setDeliveryMode(int paramInt)
    throws JMSException;
  
  public abstract int getDeliveryMode()
    throws JMSException;
  
  public abstract void setPriority(int paramInt)
    throws JMSException;
  
  public abstract int getPriority()
    throws JMSException;
  
  public abstract void setTimeToLive(long paramLong)
    throws JMSException;
  
  public abstract long getTimeToLive()
    throws JMSException;
  
  public abstract Destination getDestination()
    throws JMSException;
  
  public abstract void close()
    throws JMSException;
  
  public abstract void send(Message paramMessage)
    throws JMSException;
  
  public abstract void send(Message paramMessage, int paramInt1, int paramInt2, long paramLong)
    throws JMSException;
  
  public abstract void send(Destination paramDestination, Message paramMessage)
    throws JMSException;
  
  public abstract void send(Destination paramDestination, Message paramMessage, int paramInt1, int paramInt2, long paramLong)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.MessageProducer
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

import java.io.Serializable;

public abstract interface ObjectMessage
  extends Message
{
  public abstract void setObject(Serializable paramSerializable)
    throws JMSException;
  
  public abstract Serializable getObject()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.ObjectMessage
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface Queue
  extends Destination
{
  public abstract String getQueueName()
    throws JMSException;
  
  public abstract String toString();
}

/* Location:
 * Qualified Name:     javax.jms.Queue
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

import java.util.Enumeration;

public abstract interface QueueBrowser
{
  public abstract Queue getQueue()
    throws JMSException;
  
  public abstract String getMessageSelector()
    throws JMSException;
  
  public abstract Enumeration getEnumeration()
    throws JMSException;
  
  public abstract void close()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.QueueBrowser
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface QueueConnection
  extends Connection
{
  public abstract QueueSession createQueueSession(boolean paramBoolean, int paramInt)
    throws JMSException;
  
  public abstract ConnectionConsumer createConnectionConsumer(Queue paramQueue, String paramString, ServerSessionPool paramServerSessionPool, int paramInt)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.QueueConnection
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface QueueConnectionFactory
  extends ConnectionFactory
{
  public abstract QueueConnection createQueueConnection()
    throws JMSException;
  
  public abstract QueueConnection createQueueConnection(String paramString1, String paramString2)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.QueueConnectionFactory
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface QueueReceiver
  extends MessageConsumer
{
  public abstract Queue getQueue()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.QueueReceiver
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class QueueRequestor
{
  private QueueSession queueSession = null;
  private Queue queue = null;
  private QueueSender requestSender = null;
  private QueueReceiver replyReceiver = null;
  private TemporaryQueue replyQueue = null;
  
  public QueueRequestor(QueueSession session, Queue queue)
    throws JMSException
  {
    queueSession = session;
    this.queue = queue;
    
    requestSender = queueSession.createSender(queue);
    replyQueue = queueSession.createTemporaryQueue();
    replyReceiver = queueSession.createReceiver(replyQueue);
  }
  
  public Message request(Message message)
    throws JMSException
  {
    message.setJMSReplyTo(replyQueue);
    message.setJMSDeliveryMode(1);
    requestSender.send(message);
    return replyReceiver.receive();
  }
  
  public void close()
    throws JMSException
  {
    replyReceiver.close();
    replyQueue.delete();
    queueSession.close();
  }
}

/* Location:
 * Qualified Name:     javax.jms.QueueRequestor
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface QueueSender
  extends MessageProducer
{
  public abstract Queue getQueue()
    throws JMSException;
  
  public abstract void send(Message paramMessage)
    throws JMSException;
  
  public abstract void send(Message paramMessage, int paramInt1, int paramInt2, long paramLong)
    throws JMSException;
  
  public abstract void send(Queue paramQueue, Message paramMessage)
    throws JMSException;
  
  public abstract void send(Queue paramQueue, Message paramMessage, int paramInt1, int paramInt2, long paramLong)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.QueueSender
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface QueueSession
  extends Session
{
  public abstract Queue createQueue(String paramString)
    throws JMSException;
  
  public abstract QueueReceiver createReceiver(Queue paramQueue)
    throws JMSException;
  
  public abstract QueueReceiver createReceiver(Queue paramQueue, String paramString)
    throws JMSException;
  
  public abstract QueueSender createSender(Queue paramQueue)
    throws JMSException;
  
  public abstract QueueBrowser createBrowser(Queue paramQueue)
    throws JMSException;
  
  public abstract QueueBrowser createBrowser(Queue paramQueue, String paramString)
    throws JMSException;
  
  public abstract TemporaryQueue createTemporaryQueue()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.QueueSession
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class ResourceAllocationException
  extends JMSException
{
  public ResourceAllocationException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public ResourceAllocationException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.ResourceAllocationException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface ServerSession
{
  public abstract Session getSession()
    throws JMSException;
  
  public abstract void start()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.ServerSession
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface ServerSessionPool
{
  public abstract ServerSession getServerSession()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.ServerSessionPool
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

import java.io.Serializable;

public abstract interface Session
  extends Runnable
{
  public static final int AUTO_ACKNOWLEDGE = 1;
  public static final int CLIENT_ACKNOWLEDGE = 2;
  public static final int DUPS_OK_ACKNOWLEDGE = 3;
  public static final int SESSION_TRANSACTED = 0;
  
  public abstract BytesMessage createBytesMessage()
    throws JMSException;
  
  public abstract MapMessage createMapMessage()
    throws JMSException;
  
  public abstract Message createMessage()
    throws JMSException;
  
  public abstract ObjectMessage createObjectMessage()
    throws JMSException;
  
  public abstract ObjectMessage createObjectMessage(Serializable paramSerializable)
    throws JMSException;
  
  public abstract StreamMessage createStreamMessage()
    throws JMSException;
  
  public abstract TextMessage createTextMessage()
    throws JMSException;
  
  public abstract TextMessage createTextMessage(String paramString)
    throws JMSException;
  
  public abstract boolean getTransacted()
    throws JMSException;
  
  public abstract int getAcknowledgeMode()
    throws JMSException;
  
  public abstract void commit()
    throws JMSException;
  
  public abstract void rollback()
    throws JMSException;
  
  public abstract void close()
    throws JMSException;
  
  public abstract void recover()
    throws JMSException;
  
  public abstract MessageListener getMessageListener()
    throws JMSException;
  
  public abstract void setMessageListener(MessageListener paramMessageListener)
    throws JMSException;
  
  public abstract void run();
  
  public abstract MessageProducer createProducer(Destination paramDestination)
    throws JMSException;
  
  public abstract MessageConsumer createConsumer(Destination paramDestination)
    throws JMSException;
  
  public abstract MessageConsumer createConsumer(Destination paramDestination, String paramString)
    throws JMSException;
  
  public abstract MessageConsumer createConsumer(Destination paramDestination, String paramString, boolean paramBoolean)
    throws JMSException;
  
  public abstract Queue createQueue(String paramString)
    throws JMSException;
  
  public abstract Topic createTopic(String paramString)
    throws JMSException;
  
  public abstract TopicSubscriber createDurableSubscriber(Topic paramTopic, String paramString)
    throws JMSException;
  
  public abstract TopicSubscriber createDurableSubscriber(Topic paramTopic, String paramString1, String paramString2, boolean paramBoolean)
    throws JMSException;
  
  public abstract QueueBrowser createBrowser(Queue paramQueue)
    throws JMSException;
  
  public abstract QueueBrowser createBrowser(Queue paramQueue, String paramString)
    throws JMSException;
  
  public abstract TemporaryQueue createTemporaryQueue()
    throws JMSException;
  
  public abstract TemporaryTopic createTemporaryTopic()
    throws JMSException;
  
  public abstract void unsubscribe(String paramString)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.Session
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface StreamMessage
  extends Message
{
  public abstract boolean readBoolean()
    throws JMSException;
  
  public abstract byte readByte()
    throws JMSException;
  
  public abstract short readShort()
    throws JMSException;
  
  public abstract char readChar()
    throws JMSException;
  
  public abstract int readInt()
    throws JMSException;
  
  public abstract long readLong()
    throws JMSException;
  
  public abstract float readFloat()
    throws JMSException;
  
  public abstract double readDouble()
    throws JMSException;
  
  public abstract String readString()
    throws JMSException;
  
  public abstract int readBytes(byte[] paramArrayOfByte)
    throws JMSException;
  
  public abstract Object readObject()
    throws JMSException;
  
  public abstract void writeBoolean(boolean paramBoolean)
    throws JMSException;
  
  public abstract void writeByte(byte paramByte)
    throws JMSException;
  
  public abstract void writeShort(short paramShort)
    throws JMSException;
  
  public abstract void writeChar(char paramChar)
    throws JMSException;
  
  public abstract void writeInt(int paramInt)
    throws JMSException;
  
  public abstract void writeLong(long paramLong)
    throws JMSException;
  
  public abstract void writeFloat(float paramFloat)
    throws JMSException;
  
  public abstract void writeDouble(double paramDouble)
    throws JMSException;
  
  public abstract void writeString(String paramString)
    throws JMSException;
  
  public abstract void writeBytes(byte[] paramArrayOfByte)
    throws JMSException;
  
  public abstract void writeBytes(byte[] paramArrayOfByte, int paramInt1, int paramInt2)
    throws JMSException;
  
  public abstract void writeObject(Object paramObject)
    throws JMSException;
  
  public abstract void reset()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.StreamMessage
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface TemporaryQueue
  extends Queue
{
  public abstract void delete()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.TemporaryQueue
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface TemporaryTopic
  extends Topic
{
  public abstract void delete()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.TemporaryTopic
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface TextMessage
  extends Message
{
  public abstract void setText(String paramString)
    throws JMSException;
  
  public abstract String getText()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.TextMessage
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface Topic
  extends Destination
{
  public abstract String getTopicName()
    throws JMSException;
  
  public abstract String toString();
}

/* Location:
 * Qualified Name:     javax.jms.Topic
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface TopicConnection
  extends Connection
{
  public abstract TopicSession createTopicSession(boolean paramBoolean, int paramInt)
    throws JMSException;
  
  public abstract ConnectionConsumer createConnectionConsumer(Topic paramTopic, String paramString, ServerSessionPool paramServerSessionPool, int paramInt)
    throws JMSException;
  
  public abstract ConnectionConsumer createDurableConnectionConsumer(Topic paramTopic, String paramString1, String paramString2, ServerSessionPool paramServerSessionPool, int paramInt)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.TopicConnection
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface TopicConnectionFactory
  extends ConnectionFactory
{
  public abstract TopicConnection createTopicConnection()
    throws JMSException;
  
  public abstract TopicConnection createTopicConnection(String paramString1, String paramString2)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.TopicConnectionFactory
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface TopicPublisher
  extends MessageProducer
{
  public abstract Topic getTopic()
    throws JMSException;
  
  public abstract void publish(Message paramMessage)
    throws JMSException;
  
  public abstract void publish(Message paramMessage, int paramInt1, int paramInt2, long paramLong)
    throws JMSException;
  
  public abstract void publish(Topic paramTopic, Message paramMessage)
    throws JMSException;
  
  public abstract void publish(Topic paramTopic, Message paramMessage, int paramInt1, int paramInt2, long paramLong)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.TopicPublisher
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class TopicRequestor
{
  private TopicSession topicSession = null;
  private Topic topic = null;
  private TopicPublisher requestPublisher = null;
  private TemporaryTopic responseTopic = null;
  private TopicSubscriber responseSubscriber = null;
  
  public TopicRequestor(TopicSession session, Topic topic)
    throws JMSException
  {
    topicSession = session;
    this.topic = topic;
    requestPublisher = topicSession.createPublisher(topic);
    responseTopic = topicSession.createTemporaryTopic();
    responseSubscriber = topicSession.createSubscriber(responseTopic);
  }
  
  public Message request(Message message)
    throws JMSException
  {
    message.setJMSReplyTo(responseTopic);
    requestPublisher.publish(message);
    return responseSubscriber.receive();
  }
  
  public void close()
    throws JMSException
  {
    responseSubscriber.close();
    responseTopic.delete();
    topicSession.close();
  }
}

/* Location:
 * Qualified Name:     javax.jms.TopicRequestor
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface TopicSession
  extends Session
{
  public abstract Topic createTopic(String paramString)
    throws JMSException;
  
  public abstract TopicSubscriber createSubscriber(Topic paramTopic)
    throws JMSException;
  
  public abstract TopicSubscriber createSubscriber(Topic paramTopic, String paramString, boolean paramBoolean)
    throws JMSException;
  
  public abstract TopicSubscriber createDurableSubscriber(Topic paramTopic, String paramString)
    throws JMSException;
  
  public abstract TopicSubscriber createDurableSubscriber(Topic paramTopic, String paramString1, String paramString2, boolean paramBoolean)
    throws JMSException;
  
  public abstract TopicPublisher createPublisher(Topic paramTopic)
    throws JMSException;
  
  public abstract TemporaryTopic createTemporaryTopic()
    throws JMSException;
  
  public abstract void unsubscribe(String paramString)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.TopicSession
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface TopicSubscriber
  extends MessageConsumer
{
  public abstract Topic getTopic()
    throws JMSException;
  
  public abstract boolean getNoLocal()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.TopicSubscriber
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class TransactionInProgressException
  extends JMSException
{
  public TransactionInProgressException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public TransactionInProgressException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.TransactionInProgressException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public class TransactionRolledBackException
  extends JMSException
{
  public TransactionRolledBackException(String reason, String errorCode)
  {
    super(reason, errorCode);
  }
  
  public TransactionRolledBackException(String reason)
  {
    super(reason);
  }
}

/* Location:
 * Qualified Name:     javax.jms.TransactionRolledBackException
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface XAConnection
  extends Connection
{
  public abstract XASession createXASession()
    throws JMSException;
  
  public abstract Session createSession(boolean paramBoolean, int paramInt)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.XAConnection
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface XAConnectionFactory
{
  public abstract XAConnection createXAConnection()
    throws JMSException;
  
  public abstract XAConnection createXAConnection(String paramString1, String paramString2)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.XAConnectionFactory
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface XAQueueConnection
  extends XAConnection, QueueConnection
{
  public abstract XAQueueSession createXAQueueSession()
    throws JMSException;
  
  public abstract QueueSession createQueueSession(boolean paramBoolean, int paramInt)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.XAQueueConnection
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface XAQueueConnectionFactory
  extends XAConnectionFactory, QueueConnectionFactory
{
  public abstract XAQueueConnection createXAQueueConnection()
    throws JMSException;
  
  public abstract XAQueueConnection createXAQueueConnection(String paramString1, String paramString2)
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.XAQueueConnectionFactory
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface XAQueueSession
  extends XASession
{
  public abstract QueueSession getQueueSession()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.XAQueueSession
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

import javax.transaction.xa.XAResource;

public abstract interface XASession
  extends Session
{
  public abstract Session getSession()
    throws JMSException;
  
  public abstract XAResource getXAResource();
  
  public abstract boolean getTransacted()
    throws JMSException;
  
  public abstract void commit()
    throws JMSException;
  
  public abstract void rollback()
    throws JMSException;
}

/* Location:
 * Qualified Name:     javax.jms.XASession
 * Java Class Version: 1.1 (45.3)
 * JD-Core Version:    0.7.1
 */
package javax.jms;

public abstract interface XATopicConnection
  extends XAConnection, TopicConnection
{
  public abs
1 2

Further reading...

For more information on Java 1.5 Tiger, you may find Java 1.5 Tiger, A developer's Notebook by D. Flanagan and B. McLaughlin from O'Reilly of interest.

New!JAR listings


Copyright 2006-2017. Infinite Loop Ltd