activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [05/52] [abbrv] [partial] activemq-6 git commit: ACTIVEMQ6-4 Rename HornetQ* classes to ActiveMQ*
Date Tue, 18 Nov 2014 23:37:58 GMT
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-server/src/main/java/org/apache/activemq/core/server/HornetQMessageBundle.java
----------------------------------------------------------------------
diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/HornetQMessageBundle.java
b/activemq-server/src/main/java/org/apache/activemq/core/server/HornetQMessageBundle.java
deleted file mode 100644
index cd530c3..0000000
--- a/activemq-server/src/main/java/org/apache/activemq/core/server/HornetQMessageBundle.java
+++ /dev/null
@@ -1,371 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you 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.
- */
-
-package org.apache.activemq.core.server;
-
-import org.apache.activemq.api.core.ActiveMQAddressFullException;
-import org.apache.activemq.api.core.ActiveMQClusterSecurityException;
-import org.apache.activemq.api.core.ActiveMQConnectionTimedOutException;
-import org.apache.activemq.api.core.ActiveMQDisconnectedException;
-import org.apache.activemq.api.core.ActiveMQDuplicateMetaDataException;
-import org.apache.activemq.api.core.ActiveMQException;
-import org.apache.activemq.api.core.ActiveMQIOErrorException;
-import org.apache.activemq.api.core.ActiveMQIllegalStateException;
-import org.apache.activemq.api.core.ActiveMQIncompatibleClientServerException;
-import org.apache.activemq.api.core.ActiveMQInternalErrorException;
-import org.apache.activemq.api.core.ActiveMQInvalidFilterExpressionException;
-import org.apache.activemq.api.core.ActiveMQInvalidTransientQueueUseException;
-import org.apache.activemq.api.core.ActiveMQNonExistentQueueException;
-import org.apache.activemq.api.core.ActiveMQQueueExistsException;
-import org.apache.activemq.api.core.ActiveMQSecurityException;
-import org.apache.activemq.api.core.ActiveMQSessionCreationException;
-import org.apache.activemq.api.core.DiscoveryGroupConfiguration;
-import org.apache.activemq.api.core.SimpleString;
-import org.apache.activemq.core.postoffice.Binding;
-import org.apache.activemq.core.protocol.core.impl.wireformat.ReplicationSyncFileMessage;
-import org.apache.activemq.core.security.CheckType;
-import org.jboss.logging.annotations.Cause;
-import org.jboss.logging.annotations.Message;
-import org.jboss.logging.annotations.MessageBundle;
-import org.jboss.logging.Messages;
-
-import java.io.File;
-
-/**
- * Logger Code 11
- * <p/>
- * Each message id must be 6 digits long starting with 10, the 3rd digit should be 9. So
the range
- * is from 119000 to 119999.
- * <p/>
- * Once released, methods should not be deleted as they may be referenced by knowledge base
- * articles. Unused methods should be marked as deprecated.
- *
- * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a>
- */
-@MessageBundle(projectCode = "HQ")
-public interface HornetQMessageBundle
-{
-   HornetQMessageBundle BUNDLE = Messages.getBundle(HornetQMessageBundle.class);
-
-   @Message(id = 119000, value = "Activation for server {0}", format = Message.Format.MESSAGE_FORMAT)
-   String activationForServer(HornetQServer server);
-
-   @Message(id = 119001, value = "Generating thread dump because - {0}", format = Message.Format.MESSAGE_FORMAT)
-   String generatingThreadDump(String reason);
-
-   @Message(id = 119002, value = "Thread {0} name = {1} id = {2} group = {3}", format = Message.Format.MESSAGE_FORMAT)
-   String threadDump(Thread key, String name, Long id, ThreadGroup threadGroup);
-
-   @Message(id = 119003, value = "End Thread dump", format = Message.Format.MESSAGE_FORMAT)
-   String endThreadDump();
-
-   @Message(id = 119004, value = "Information about server {0}\nCluster Connection:{1}",
format = Message.Format.MESSAGE_FORMAT)
-   String serverDescribe(String identity, String describe);
-
-   @Message(id = 119005, value = "connections for {0} closed by management", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException connectionsClosedByManagement(String ipAddress);
-
-   @Message(id = 119006, value = "journals are not JournalImpl. You can''t set a replicator!",
format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException notJournalImpl();
-
-   @Message(id = 119007, value = "unhandled error during replication", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException replicationUnhandledError(@Cause Exception e);
-
-   @Message(id = 119008, value = "Live Node contains more journals than the backup node.
Probably a version match error", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException replicationTooManyJournals();
-
-   @Message(id = 119009, value = "Unhandled file type {0}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException replicationUnhandledFileType(ReplicationSyncFileMessage.FileType
fileType);
-
-   @Message(id = 119010, value = "Remote Backup can not be up-to-date!", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException replicationBackupUpToDate();
-
-   @Message(id = 119011, value = "unhandled data type!", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException replicationUnhandledDataType();
-
-   @Message(id = 119012, value = "No binding for divert {0}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException noBindingForDivert(SimpleString name);
-
-   @Message(id = 119013, value = "Binding {0} is not a divert", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException bindingNotDivert(SimpleString name);
-
-   @Message(id = 119014,
-            value = "Did not receive data from {0}. It is likely the client has exited or
crashed without "
-               +
-               "closing its connection, or the network between the server and client has
failed. " +
-               "You also might have configured connection-ttl and client-failure-check-period
incorrectly. " +
-               "Please check user manual for more information." +
-               " The connection will now be closed.", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQConnectionTimedOutException clientExited(String remoteAddress);
-
-   @Message(id = 119015, value = "Timeout on waiting I/O completion", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIOErrorException ioTimeout();
-
-   @Message(id = 119016, value = "queue {0} has been removed cannot deliver message, queues
should not be removed when grouping is used", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQNonExistentQueueException groupingQueueRemoved(SimpleString chosenClusterName);
-
-   @Message(id = 119017, value = "Queue {0} does not exist", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQNonExistentQueueException noSuchQueue(SimpleString queueName);
-
-   @Message(id = 119018, value = "Binding already exists {0}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQQueueExistsException bindingAlreadyExists(Binding binding);
-
-   @Message(id = 119019, value = "Queue already exists {0}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQQueueExistsException queueAlreadyExists(SimpleString queueName);
-
-   @Message(id = 119020, value = "Invalid filter: {0}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInvalidFilterExpressionException invalidFilter(@Cause Throwable e, SimpleString
filter);
-
-   @Message(id = 119021, value = "MessageId was not assigned to Message", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException messageIdNotAssigned();
-
-   @Message(id = 119022, value = "Cannot compare journals if not in sync!", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException journalsNotInSync();
-
-   @Message(id = 119023, value = "Connected server is not a backup server", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException serverNotBackupServer();
-
-   @Message(id = 119024, value = "Backup replication server is already connected to another
server", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException alreadyHaveReplicationServer();
-
-   @Message(id = 119025, value = "Cannot delete queue {0} on binding {1} - it has consumers
= {2}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException cannotDeleteQueue(SimpleString name, SimpleString queueName,
String s);
-
-   @Message(id = 119026, value = "Backup Server was not yet in sync with live", format =
Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException backupServerNotInSync();
-
-   @Message(id = 119027, value = "Could not find reference on consumer ID={0}, messageId
= {1} queue = {2}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException consumerNoReference(Long id, Long messageID, SimpleString
name);
-
-   @Message(id = 119028, value = "Consumer {0} doesn''t exist on the server", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException consumerDoesntExist(long consumerID);
-
-   @Message(id = 119029, value = "No address configured on the Server''s Session", format
= Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException noAddress();
-
-   @Message(id = 119030, value = "large-message not initialized on server", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException largeMessageNotInitialised();
-
-   @Message(id = 119031, value = "Unable to validate user: {0}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQSecurityException unableToValidateUser(String user);
-
-   @Message(id = 119032, value = "User: {0} does not have permission=''{1}'' on address {2}",
format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQSecurityException userNoPermissions(String username, CheckType checkType, String
saddress);
-
-   @Message(id = 119033, value = "Server and client versions incompatible", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIncompatibleClientServerException incompatibleClientServer();
-
-   @Message(id = 119034, value = "Server not started", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQSessionCreationException serverNotStarted();
-
-   @Message(id = 119035, value = "Metadata {0}={1} had been set already", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQDuplicateMetaDataException duplicateMetadata(String key, String data);
-
-   @Message(id = 119036, value = "Invalid type: {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidType(Object type);
-
-   @Message(id = 119037, value = "retry interval must be positive, was {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidRetryInterval(Long size);
-
-   @Message(id = 119038, value = "{0} must neither be null nor empty", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException emptyOrNull(String name);
-
-   @Message(id = 119039, value = "{0}  must be greater than 0 (actual value: {1})", format
= Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException greaterThanZero(String name, Number val);
-
-   @Message(id = 119040, value = "{0} must be a valid percentual value between 0 and 100
(actual value: {1})", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException notPercent(String name, Number val);
-
-   @Message(id = 119041, value = "{0}  must be equals to -1 or greater than 0 (actual value:
{1})", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException greaterThanMinusOne(String name, Number val);
-
-   @Message(id = 119042, value = "{0}  must be equals to -1 or greater or equals to 0 (actual
value: {1})", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException greaterThanZeroOrMinusOne(String name, Number val);
-
-   @Message(id = 119043, value = "{0} must be between {1} and {2} inclusive (actual value:
{3})", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException mustbeBetween(String name, Integer minPriority, Integer maxPriority,
Object value);
-
-   @Message(id = 119044, value = "Invalid journal type {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidJournalType(String val);
-
-   @Message(id = 119045, value = "Invalid address full message policy type {0}", format =
Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidAddressFullPolicyType(String val);
-
-   @Message(id = 119046, value = "invalid value: {0} count must be greater than 0", format
= Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException greaterThanZero(Integer count);
-
-   @Message(id = 119047, value = "Cannot set Message Counter Sample Period < {0}ms", format
= Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidMessageCounterPeriod(Long period);
-
-   @Message(id = 119048, value = "invalid new Priority value: {0}. It must be between 0 and
9 (both included)", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidNewPriority(Integer period);
-
-   @Message(id = 119049, value = "No queue found for {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException noQueueFound(String otherQueueName);
-
-   @Message(id = 119050, value = "Only NIO and AsyncIO are supported journals", format =
Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidJournal();
-
-   @Message(id = 119051, value = "Invalid journal type {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidJournalType2(JournalType journalType);
-
-   @Message(id = 119052, value = "Directory {0} does not exist and cannot be created", format
= Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException cannotCreateDir(String dir);
-
-   @Message(id = 119053, value = "Invalid index {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidIndex(Integer index);
-
-   @Message(id = 119054, value = "Cannot convert to int", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException cannotConvertToInt();
-
-   @Message(id = 119055, value = "Routing name is null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException routeNameIsNull();
-
-   @Message(id = 119056, value = "Cluster name is null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException clusterNameIsNull();
-
-   @Message(id = 119057, value = "Address is null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException addressIsNull();
-
-   @Message(id = 119058, value = "Binding type not specified", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException bindingTypeNotSpecified();
-
-   @Message(id = 119059, value = "Binding ID is null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException bindingIdNotSpecified();
-
-   @Message(id = 119060, value = "Distance is null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException distancenotSpecified();
-
-   @Message(id = 119061, value = "Connection already exists with id {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException connectionExists(Object id);
-
-   @Message(id = 119062, value = "Acceptor with id {0} already registered", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException acceptorExists(Integer id);
-
-   @Message(id = 119063, value = "Acceptor with id {0} not registered", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException acceptorNotExists(Integer id);
-
-   @Message(id = 119064, value = "Unknown protocol {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException unknownProtocol(String protocol);
-
-   @Message(id = 119065, value = "node id is null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException nodeIdNull();
-
-   @Message(id = 119066, value = "Queue name is null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException queueNameIsNull();
-
-   @Message(id = 119067, value = "Cannot find resource with name {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException cannotFindResource(String resourceName);
-
-   @Message(id = 119068, value = "no getter method for {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException noGetterMethod(String resourceName);
-
-   @Message(id = 119069, value = "no operation {0}/{1}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException noOperation(String operation, Integer length);
-
-   @Message(id = 119070, value = "match can not be null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException nullMatch();
-
-   @Message(id = 119071, value = "# can only be at end of match", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidMatch();
-
-   @Message(id = 119072, value = "User cannot be null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException nullUser();
-
-   @Message(id = 119073, value = "Password cannot be null", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException nullPassword();
-
-   @Message(id = 119074, value = "Error instantiating transformer class {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException errorCreatingTransformerClass(@Cause Exception e, String transformerClassName);
-
-   @Message(id = 119075, value = "method autoEncode doesn''t know how to convert {0} yet",
format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException autoConvertError(Class<? extends Object> aClass);
-
-   /**
-    * Message used on on {@link org.apache.activemq.core.server.impl.HornetQServerImpl#destroyConnectionWithSessionMetadata(String,
String)}
-    */
-   @Message(id = 119076, value = "Executing destroyConnection with {0}={1} through management''s
request", format = Message.Format.MESSAGE_FORMAT)
-   String destroyConnectionWithSessionMetadataHeader(String key, String value);
-
-   /**
-    * Message used on on {@link org.apache.activemq.core.server.impl.HornetQServerImpl#destroyConnectionWithSessionMetadata(String,
String)}
-    */
-   @Message(id = 119077, value = "Closing connection {0}", format = Message.Format.MESSAGE_FORMAT)
-   String destroyConnectionWithSessionMetadataClosingConnection(String serverSessionString);
-
-   /**
-    * Exception used on on {@link org.apache.activemq.core.server.impl.HornetQServerImpl#destroyConnectionWithSessionMetadata(String,
String)}
-    */
-   @Message(id = 119078, value = "Disconnected per admin''s request on {0}={1}", format =
Message.Format.MESSAGE_FORMAT)
-   ActiveMQDisconnectedException destroyConnectionWithSessionMetadataSendException(String
key, String value);
-
-   /**
-    * Message used on on {@link org.apache.activemq.core.server.impl.HornetQServerImpl#destroyConnectionWithSessionMetadata(String,
String)}
-    */
-   @Message(id = 119079, value = "No session found with {0}={1}", format = Message.Format.MESSAGE_FORMAT)
-   String destroyConnectionWithSessionMetadataNoSessionFound(String key, String value);
-
-   @Message(id = 119080, value = "Invalid Page IO, PagingManager was stopped or closed",
format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException invalidPageIO();
-
-   @Message(id = 119081, value = "No Discovery Group configuration named {0} found", format
= Message.Format.MESSAGE_FORMAT)
-   ActiveMQException noDiscoveryGroupFound(DiscoveryGroupConfiguration dg);
-
-   @Message(id = 119082, value = "Queue {0} already exists on another subscription", format
= Message.Format.MESSAGE_FORMAT)
-   ActiveMQInvalidTransientQueueUseException queueSubscriptionBelongsToDifferentAddress(SimpleString
queueName);
-
-   @Message(id = 119083, value = "Queue {0} has a different filter than requested", format
= Message.Format.MESSAGE_FORMAT)
-   ActiveMQInvalidTransientQueueUseException queueSubscriptionBelongsToDifferentFilter(SimpleString
queueName);
-
-   @Message(id = 119085, value = "Classpath lacks a protocol-manager for protocol {0}",
-            format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQException noProtocolManagerFound(String protocol);
-
-   // this code has to match with version 2.3.x as it's used on integration tests at Wildfly
and JBoss EAP
-   @Message(id = 119099, value = "Unable to authenticate cluster user: {0}",
-            format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQClusterSecurityException unableToValidateClusterUser(String user);
-
-
-   @Message(id = 119100, value = "Trying to move a journal file that refers to a file instead
of a directory: {0}",
-            format = Message.Format.MESSAGE_FORMAT)
-   IllegalStateException journalDirIsFile(File fDir);
-
-   @Message(id = 119101, value = "error trying to backup journal files at directory: {0}",
-            format = Message.Format.MESSAGE_FORMAT)
-   IllegalStateException couldNotMoveJournal(File dir);
-
-   @Message(id = 119102, value = "Address \"{0}\" is full.", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQAddressFullException addressIsFull(String addressName);
-
-   @Message(id = 119103, value = "No Connectors or Discovery Groups configured for Scale
Down", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQException noConfigurationFoundForScaleDown();
-
-   @Message(id = 119104, value = "Server is stopping. Message grouping not allowed", format
= Message.Format.MESSAGE_FORMAT)
-   ActiveMQException groupWhileStopping();
-
-   @Message(id = 119105, value = "Server will not accept create session request since scale
down has not occurred", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQSessionCreationException sessionNotFailedOver();
-
-   @Message(id = 119106, value = "Invalid slow consumer policy type {0}", format = Message.Format.MESSAGE_FORMAT)
-   IllegalArgumentException invalidSlowConsumerPolicyType(String val);
-
-   @Message(id = 119107, value = "consumer connections for address {0} closed by management",
format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException consumerConnectionsClosedByManagement(String address);
-
-   @Message(id = 119108, value = "connections for user {0} closed by management", format
= Message.Format.MESSAGE_FORMAT)
-   ActiveMQInternalErrorException connectionsForUserClosedByManagement(String userName);
-
-   @Message(id = 119109, value = "unsupported HA Policy Configuration {0}", format = Message.Format.MESSAGE_FORMAT)
-   ActiveMQIllegalStateException unsupportedHAPolicyConfiguration(Object o);
-}

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/034adfbf/activemq-server/src/main/java/org/apache/activemq/core/server/HornetQServer.java
----------------------------------------------------------------------
diff --git a/activemq-server/src/main/java/org/apache/activemq/core/server/HornetQServer.java
b/activemq-server/src/main/java/org/apache/activemq/core/server/HornetQServer.java
deleted file mode 100644
index fa493ae..0000000
--- a/activemq-server/src/main/java/org/apache/activemq/core/server/HornetQServer.java
+++ /dev/null
@@ -1,249 +0,0 @@
-/*
- * Copyright 2005-2014 Red Hat, Inc.
- * Red Hat licenses this file to you 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.
- */
-package org.apache.activemq.core.server;
-
-import java.util.List;
-import java.util.Set;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
-import org.apache.activemq.api.core.SimpleString;
-import org.apache.activemq.core.config.BridgeConfiguration;
-import org.apache.activemq.core.config.Configuration;
-import org.apache.activemq.core.config.DivertConfiguration;
-import org.apache.activemq.core.management.impl.HornetQServerControlImpl;
-import org.apache.activemq.core.paging.PagingManager;
-import org.apache.activemq.core.persistence.StorageManager;
-import org.apache.activemq.core.postoffice.PostOffice;
-import org.apache.activemq.core.remoting.server.RemotingService;
-import org.apache.activemq.core.replication.ReplicationManager;
-import org.apache.activemq.core.security.Role;
-import org.apache.activemq.core.security.SecurityStore;
-import org.apache.activemq.core.server.cluster.ClusterManager;
-import org.apache.activemq.core.server.cluster.ha.HAPolicy;
-import org.apache.activemq.core.server.group.GroupingHandler;
-import org.apache.activemq.core.server.impl.Activation;
-import org.apache.activemq.core.server.impl.ConnectorsService;
-import org.apache.activemq.core.server.management.ManagementService;
-import org.apache.activemq.core.settings.HierarchicalRepository;
-import org.apache.activemq.core.settings.impl.AddressSettings;
-import org.apache.activemq.core.transaction.ResourceManager;
-import org.apache.activemq.core.version.Version;
-import org.apache.activemq.spi.core.protocol.ProtocolManagerFactory;
-import org.apache.activemq.spi.core.protocol.RemotingConnection;
-import org.apache.activemq.spi.core.protocol.SessionCallback;
-import org.apache.activemq.spi.core.security.HornetQSecurityManager;
-import org.apache.activemq.utils.ExecutorFactory;
-
-/**
- * This interface defines the internal interface of the HornetQ Server exposed to other components
- * of the server.
- * <p>
- * This is not part of our public API.
- * @author <a href="tim.fox@jboss.com">Tim Fox</a>
- * @author <a href="ataylor@redhat.com">Andy Taylor</a>
- */
-public interface HornetQServer extends HornetQComponent
-{
-
-   /**
-    * Sets the server identity.
-    * <p>
-    * The identity will be exposed on logs. It may help to debug issues on the log traces
and
-    * debugs.
-    * <p>
-    * This method was created mainly for testing but it may be used in scenarios where you
need to
-    * have more than one Server inside the same VM.
-    */
-   void setIdentity(String identity);
-
-   String getIdentity();
-
-   String describe();
-
-   void addActivationParam(String key, Object val);
-
-   Configuration getConfiguration();
-
-   RemotingService getRemotingService();
-
-   StorageManager getStorageManager();
-
-   PagingManager getPagingManager();
-
-   ManagementService getManagementService();
-
-   HornetQSecurityManager getSecurityManager();
-
-   Version getVersion();
-
-   NodeManager getNodeManager();
-
-   /**
-    * Returns the resource to manage this HornetQ server.
-    * @throws IllegalStateException if the server is not properly started.
-    */
-   HornetQServerControlImpl getHornetQServerControl();
-
-   void registerActivateCallback(ActivateCallback callback);
-
-   void unregisterActivateCallback(ActivateCallback callback);
-
-   ServerSession createSession(String name,
-                               String username,
-                               String password,
-                               int minLargeMessageSize,
-                               RemotingConnection remotingConnection,
-                               boolean autoCommitSends,
-                               boolean autoCommitAcks,
-                               boolean preAcknowledge,
-                               boolean xa,
-                               String defaultAddress,
-                               SessionCallback callback,
-                               ServerSessionFactory sessionFactory) throws Exception;
-
-   SecurityStore getSecurityStore();
-
-   void removeSession(String name) throws Exception;
-
-   Set<ServerSession> getSessions();
-
-   HierarchicalRepository<Set<Role>> getSecurityRepository();
-
-   HierarchicalRepository<AddressSettings> getAddressSettingsRepository();
-
-   int getConnectionCount();
-
-   PostOffice getPostOffice();
-
-   QueueFactory getQueueFactory();
-
-   ResourceManager getResourceManager();
-
-   List<ServerSession> getSessions(String connectionID);
-
-   /** @return a session containing the meta-key and meata-value */
-   ServerSession lookupSession(String metakey, String metavalue);
-
-   ClusterManager getClusterManager();
-
-   SimpleString getNodeID();
-
-   boolean isActive();
-
-   /**
-    * Wait for server initialization.
-    * @param timeout
-    * @param unit
-    * @see CountDownLatch#await(long, TimeUnit)
-    * @return {@code true} if the server was already initialized or if it was initialized
within the
-    *         timeout period, {@code false} otherwise.
-    * @throws InterruptedException
-    */
-   boolean waitForActivation(long timeout, TimeUnit unit) throws InterruptedException;
-
-   /**
-    * Creates a shared queue. if non durable it will exist as long as there are consumers.
-    *
-    * Notice: the queue won't be deleted until the first consumer arrives.
-    *
-    * @param address
-    * @param name
-    * @param filterString
-    * @param durable
-    * @throws Exception
-    */
-   void createSharedQueue(final SimpleString address,
-                           final SimpleString name,
-                           final SimpleString filterString,
-                           boolean durable) throws Exception;
-
-   Queue createQueue(SimpleString address,
-                     SimpleString queueName,
-                     SimpleString filter,
-                     boolean durable,
-                     boolean temporary) throws Exception;
-
-   Queue deployQueue(SimpleString address,
-                     SimpleString queueName,
-                     SimpleString filterString,
-                     boolean durable,
-                     boolean temporary) throws Exception;
-
-   Queue locateQueue(SimpleString queueName) throws Exception;
-
-   void destroyQueue(SimpleString queueName) throws Exception;
-
-   void destroyQueue(SimpleString queueName, ServerSession session) throws Exception;
-
-   void destroyQueue(SimpleString queueName, ServerSession session, boolean checkConsumerCount)
throws Exception;
-
-   void destroyQueue(SimpleString queueName, ServerSession session, boolean checkConsumerCount,
boolean removeConsumers) throws Exception;
-
-   String destroyConnectionWithSessionMetadata(String metaKey, String metaValue) throws Exception;
-
-   ScheduledExecutorService getScheduledPool();
-
-   ExecutorFactory getExecutorFactory();
-
-   void setGroupingHandler(GroupingHandler groupingHandler);
-
-   GroupingHandler getGroupingHandler();
-
-   ReplicationManager getReplicationManager();
-
-   void deployDivert(DivertConfiguration config) throws Exception;
-
-   void destroyDivert(SimpleString name) throws Exception;
-
-   ConnectorsService getConnectorsService();
-
-   void deployBridge(BridgeConfiguration config) throws Exception;
-
-   void destroyBridge(String name) throws Exception;
-
-   ServerSession getSessionByID(String sessionID);
-
-   void threadDump(String reason);
-
-   /**
-    * return true if there is a binding for this address (i.e. if there is a created queue)
-    * @param address
-    * @return
-    */
-   boolean isAddressBound(String address) throws Exception;
-
-   void stop(boolean failoverOnServerShutdown) throws Exception;
-
-   /*
-   * add a ProtocolManagerFactory to be used. Note if @see Configuration#isResolveProtocols
is tur then this factory will
-   * replace any factories with the same protocol
-   * */
-   void addProtocolManagerFactory(ProtocolManagerFactory factory);
-
-   /*
-   * add a ProtocolManagerFactory to be used.
-   * */
-   void removeProtocolManagerFactory(ProtocolManagerFactory factory);
-
-   HornetQServer createBackupServer(Configuration configuration);
-
-   void addScaledDownNode(SimpleString scaledDownNodeId);
-
-   boolean hasScaledDown(SimpleString scaledDownNodeId);
-
-   Activation getActivation();
-
-   HAPolicy getHAPolicy();
-
-   void setHAPolicy(HAPolicy haPolicy);
-}


Mime
View raw message