safmq.src.0.5.gz_MQ-2_saf_中间件 服务器_中间件服务器_消息队列

/* Copyright 2005 Matthew J. Battey Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. This software implements a Java interface to SAFMQ (see http://safmq.sourceforge.net). Created on Mar 21, 2005 */ package com.safmq; import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.net.Socket; import java.net.URI; import java.util.Vector; /** * This class provides an interface to communicate with a SAFMQ message queue * server. Typically instances of this class are constructed by the * <code>MQBuilder</code> class, however constructing the class directly * is also allowed. * * <p>Once constructed, this class may be used to construct * instances of the class <code>MessageQueue</code> to abstract the connection * interface to the message queue level.</p> * * <p><b>Note:</b> This class is not thread safe, and applications should * take precautions to not initiate communications with a message queue via * more than one (1) thread simultaneously.</p> * * @author Matt * @see MQBuilder#buildConnection(URI,String,String) * @see MessageQueue */ public class MQConnection { final static String FORWARD_QUEUE_NAME = "_FORWARD_"; Socket s; DataInputStream in; DataOutputStream out; int server_major_protocol_version; int server_minor_protocol_version; /** * Result data from a call to <code>MQConnection.EnumerateQueues(Vector)</code>. * Instances of this class are placed into the vector passed to * <code>EnumerateQueues()</code> to detail the specifics of the queue. * * @author matt * @see MQConnection#EnumerateQueues(Vector) MQConnection.EnumerateQueues(Vector) */ public class QueueData { String name; String owner; /** * Constructs the QueueData object from the queue's name and owner. * @param name The name of the queue. * @param owner The name of the queue's owner. */ QueueData(String name, String owner) { this.name = name; this.owner = owner; } /** * Provides the queue's name. * @return The queue's name. */ public String getName() { return name; } /** * Provides the queue's owner's name. * @return The queue's owner's name. */ public String getOwner() { return owner; } } /** * Contains an entity's permisison when accessing a queue. * * @author Matt */ public class QueuePermissions { String entityName; boolean isgroup; boolean read; boolean write; boolean destroy; boolean changeSecurity; /** * Constructs the QueuePermissions from the name of the entity and * flags regarding its relationsihp with the queried queue. This object * is used as a result to * <code>MQConnection.queueEnumeratePermissions(String,Vector)</code>. * * @param entityName The name of the entity these permissions pertain to * @param isgroup A flag indicating this entity is a group (otherwise * a user) * @param read A flag indicating whether this entity may read from * the queue * @param write A flag indicating whether this entity may write to * the queue * @param destroy A flag indicating whether this entity may remove the * queue from the server * @param changeSecurity A flag indicating whether this entity may change * the security permissions of the queue */ QueuePermissions(String entityName, boolean isgroup, boolean read, boolean write, boolean destroy, boolean changeSecurity) { this.entityName = entityName; this.isgroup = isgroup; this.read = read; this.write = write; this.destroy = destroy; this.changeSecurity = changeSecurity; } /** * Provides the name of the entity these permissions pertain to. * @return Returns the name of the entity these permissions pertain to. */ public String getEntityName() { return entityName; } /** * Provides the flag whether this entity may remove the queue from the server. * * @return Returns the flag whether this entity may remove the queue from the server. */ public boolean getDestroy() { return destroy; } /** * Provids a flag whether this entity is a group. * @return Returns a flag whether this entity is a group. */ public boolean getIsGroup() { return isgroup; } /** * Provides a flag whether this entity is allowed to read from the queue. * @return Returns a flag whether this entity is allowed to read from the queue. */ public boolean getRead() { return read; } /** * Provides a flag whether this entity is allowed to write to the queue. * @return Returns a flag whether this entity is allowed to write to the queue. */ public boolean getWrite() { return write; } /** * Provides a flag whether the entity is allowed to change the security for the queue. * @return The a flag whether the entity is allowed to change the security for the queue. */ public boolean getChangeSecurity() { return changeSecurity; } } /** * Result data from a call to <code>MQConnection.EnumerateUsers(Vector)</code>. * Instances of this class are placed into the vector passed to * <code>EnumerateUsers()</code> to detail the specifics of the user. * * @author matt */ public class UserDescription { String name; String description; /** * Constructs the object from the user's name and description. * * @param name The name of the user * @param description The description of the user */ UserDescription(String name, String description) { this.name = name; this.description = description; } /** * Provides the name of the user * @return The name of the user */ public String getName() { return name; } /** * Provides the description of the user * @return The description of the user */ public String getDescription() { return description; } public boolean equals(Object o) { return o != null && (this==o || ((o instanceof UserDescription) && ((UserDescription)o).getName().equals(getName())) || o.equals(getName())); } public String toString() { return getClass().getName()+":["+getName()+"]"; } } /** * For external use of UserDescriptions. * * @param name Name of the account * @param desc Description of the account * @return A newly allocated <code>UserDescription</code> object. */ public UserDescription genDesc(String name, String desc) { return new UserDescription(name,desc); } /** * Constructs the object from the name of the server, the tcp/ip port to be used * the user's name and password. * * @param server The network name of the server to be contacted * @param port The TCP/IP port to be utilized in communications with the server * @param user The name of the user wishing to connect to the server * @param password The password of the user wishing to connect to the server * @throws MQException In the case that the supplied credentials are not accepted by * the SAFMQ server. The value of <code>MQException.getErrorCode()</code> * could be but is not limited to: *<table border=0 cellpadding=3 cellspac