[jboss-cvs] JBoss Messaging SVN: r7377 - in trunk: examples/common/src/org/jboss/common/example and 7 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed Jun 17 04:21:46 EDT 2009
Author: jmesnil
Date: 2009-06-17 04:21:46 -0400 (Wed, 17 Jun 2009)
New Revision: 7377
Modified:
trunk/docs/user-manual/en/management.xml
trunk/examples/common/src/org/jboss/common/example/JBMExample.java
trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java
trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java
trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java
trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSManagementHelper.java
trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailoverManagementTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/JMSQueueControlUsingJMSTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/JMSServerControlUsingJMSTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/TopicControlUsingJMSTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/AcceptorControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/AddressControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/BridgeControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/BroadcastGroupControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/ClusterConnectionControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/DiscoveryGroupControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/DivertControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/ManagementServiceImplTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/MessagingServerControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/QueueControlUsingCoreTest.java
trunk/tests/src/org/jboss/messaging/tests/integration/management/SecurityManagementTestBase.java
Log:
JBMESSAGING:1653: specify the management attribute as lower-cased in management messages
* ManagementService will now upper-case the 1st character when looking for a getter method to invoke
for a given management attribute
* updated doc
Modified: trunk/docs/user-manual/en/management.xml
===================================================================
--- trunk/docs/user-manual/en/management.xml 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/docs/user-manual/en/management.xml 2009-06-17 08:21:46 UTC (rev 7377)
@@ -540,7 +540,7 @@
ClientSession session = ...
ClientRequestor requestor = new ClientRequestor(session, "jbm.management");
ClientMessage message = session.createClientMessage(false);
- ManagementHelper.putAttribute(message, "core.queue.exampleQueue", "MessageCount");
+ ManagementHelper.putAttribute(message, "core.queue.exampleQueue", "messageCount");
ClientMessage reply = requestor.request(m);
int count = (Integer) ManagementHelper.getResult(reply);
System.out.println("There are " + count + " messages in exampleQueue");
@@ -615,7 +615,7 @@
QueueRequestor requestor = new QueueRequestor(session, managementQueue);
connection.start();
Message message = session.createMessage();
- JMSManagementHelper.putAttribute(message, "jms.queue.exampleQueue", "MessageCount");
+ JMSManagementHelper.putAttribute(message, "jms.queue.exampleQueue", "managementQueueessageCount");
Message reply = requestor.request(message);
int count = (Integer)JMSManagementHelper.getResult(reply);
System.out.println("There are " + count + " messages in exampleQueue");
@@ -840,16 +840,16 @@
// retrieve a connection to JBoss Messaging's MBeanServer
MBeanServerConnection mbsc = ...
JMSQueueControlMBean queueControl = (JMSQueueControl)MBeanServerInvocationHandler.newProxyInstance(mbsc,
-on,
-JMSQueueControl.class,
-false);
+ on,
+ JMSQueueControl.class,
+ false);
// message counters are retrieved as a JSON String
String counters = queueControl.listMessageCounter();
// use the MessageCounterInfo helper class to manipulate message counters more easily
MessageCounterInfo messageCounter = MessageCounterInfo.fromJSON(counters);
System.out.format("%s message(s) in the queue (since last sample: %s)\n",
-counter.getDepth(),
-counter.getDepthDelta());
+ counter.getDepth(),
+ counter.getDepthDelta());
</programlisting>
</section>
<section>
Modified: trunk/examples/common/src/org/jboss/common/example/JBMExample.java
===================================================================
--- trunk/examples/common/src/org/jboss/common/example/JBMExample.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/examples/common/src/org/jboss/common/example/JBMExample.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -196,11 +196,11 @@
{
if (server.getInputStream() != null)
{
- server.getInputStream().close();
+ //server.getInputStream().close();
}
if (server.getErrorStream() != null)
{
- server.getErrorStream().close();
+ //server.getErrorStream().close();
}
}
server.destroy();
Modified: trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java
===================================================================
--- trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -96,8 +96,8 @@
// Step 13. Use a helper class to fill the JMS message with management information:
// * the name of the resource to manage
- // * in this case, we want to retrieve the value of the MessageCount of the queue
- JMSManagementHelper.putAttribute(m, "jms.queue.exampleQueue", "MessageCount");
+ // * in this case, we want to retrieve the value of the messageCount of the queue
+ JMSManagementHelper.putAttribute(m, "jms.queue.exampleQueue", "messageCount");
// Step 14. Use the requestor to send the request and wait for the reply
Message reply = requestor.request(m);
Modified: trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java
===================================================================
--- trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -145,7 +145,7 @@
Message m = session.createMessage();
- JMSManagementHelper.putAttribute(m, "jms.queue.exampleQueue", "MessageCount");
+ JMSManagementHelper.putAttribute(m, "jms.queue.exampleQueue", "messageCount");
Message response = requestor.request(m);
Modified: trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/src/main/org/jboss/messaging/core/management/impl/ManagementServiceImpl.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -694,15 +694,16 @@
Method method = null;
+ String upperCaseAttribute = attribute.substring(0, 1).toUpperCase() + attribute.substring(1);
try
{
- method = resource.getClass().getMethod("get" + attribute, new Class[0]);
+ method = resource.getClass().getMethod("get" + upperCaseAttribute, new Class[0]);
}
catch (NoSuchMethodException nsme)
{
try
{
- method = resource.getClass().getMethod("is" + attribute, new Class[0]);
+ method = resource.getClass().getMethod("is" + upperCaseAttribute, new Class[0]);
}
catch (NoSuchMethodException nsme2)
{
@@ -795,5 +796,6 @@
return result;
}
+
// Inner classes -------------------------------------------------
}
Modified: trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSManagementHelper.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSManagementHelper.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/src/main/org/jboss/messaging/jms/server/management/impl/JMSManagementHelper.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -26,7 +26,6 @@
import org.jboss.messaging.core.client.management.impl.ManagementHelper;
import org.jboss.messaging.jms.client.JBossMessage;
-import org.jboss.messaging.utils.json.JSONArray;
/*
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailoverManagementTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailoverManagementTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/cluster/failover/FailoverManagementTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -115,7 +115,7 @@
ManagementHelper.putAttribute(managementMessage,
ResourceNames.CORE_QUEUE + ADDRESS,
- "MessageCount");
+ "messageCount");
managementMessage.putStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME, replyTo);
producer.send(DEFAULT_MANAGEMENT_ADDRESS, managementMessage);
@@ -134,7 +134,7 @@
ManagementHelper.putAttribute(managementMessage,
ResourceNames.CORE_QUEUE + ADDRESS,
- "MessageCount");
+ "messageCount");
managementMessage.putStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME, replyTo);
producer.send(DEFAULT_MANAGEMENT_ADDRESS, managementMessage);
@@ -204,7 +204,7 @@
ManagementHelper.putAttribute(managementMessage,
ResourceNames.CORE_QUEUE + ADDRESS,
- "MessageCount");
+ "messageCount");
managementMessage.putStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME, replyTo);
producer.send(DEFAULT_MANAGEMENT_ADDRESS, managementMessage);
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/JMSQueueControlUsingJMSTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/JMSQueueControlUsingJMSTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/JMSQueueControlUsingJMSTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -113,52 +113,52 @@
public int getConsumerCount()
{
- return (Integer)proxy.retrieveAttributeValue("ConsumerCount");
+ return (Integer)proxy.retrieveAttributeValue("consumerCount");
}
public String getDeadLetterAddress()
{
- return (String)proxy.retrieveAttributeValue("DeadLetterAddress");
+ return (String)proxy.retrieveAttributeValue("deadLetterAddress");
}
public int getDeliveringCount()
{
- return (Integer)proxy.retrieveAttributeValue("DeliveringCount");
+ return (Integer)proxy.retrieveAttributeValue("deliveringCount");
}
public String getExpiryAddress()
{
- return (String)proxy.retrieveAttributeValue("ExpiryAddress");
+ return (String)proxy.retrieveAttributeValue("expiryAddress");
}
public int getMessageCount()
{
- return (Integer)proxy.retrieveAttributeValue("MessageCount");
+ return (Integer)proxy.retrieveAttributeValue("messageCount");
}
public int getMessagesAdded()
{
- return (Integer)proxy.retrieveAttributeValue("MessagesAdded");
+ return (Integer)proxy.retrieveAttributeValue("messagesAdded");
}
public String getName()
{
- return (String)proxy.retrieveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("name");
}
public long getScheduledCount()
{
- return (Long)proxy.retrieveAttributeValue("ScheduledCount");
+ return (Long)proxy.retrieveAttributeValue("scheduledCount");
}
public boolean isDurable()
{
- return (Boolean)proxy.retrieveAttributeValue("Durable");
+ return (Boolean)proxy.retrieveAttributeValue("durable");
}
public boolean isTemporary()
{
- return (Boolean)proxy.retrieveAttributeValue("Temporary");
+ return (Boolean)proxy.retrieveAttributeValue("temporary");
}
public Map<String, Object>[] listAllMessages() throws Exception
@@ -255,7 +255,7 @@
public String getAddress()
{
- return (String)proxy.retrieveAttributeValue("Address");
+ return (String)proxy.retrieveAttributeValue("address");
}
public String getJNDIBinding()
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/JMSServerControlUsingJMSTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/JMSServerControlUsingJMSTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/JMSServerControlUsingJMSTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -359,12 +359,12 @@
public String getVersion()
{
- return (String)proxy.retrieveAttributeValue("Version");
+ return (String)proxy.retrieveAttributeValue("version");
}
public boolean isStarted()
{
- return (Boolean)proxy.retrieveAttributeValue("Started");
+ return (Boolean)proxy.retrieveAttributeValue("started");
}
public String[] listConnectionIDs() throws Exception
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/TopicControlUsingJMSTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/TopicControlUsingJMSTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/jms/server/management/TopicControlUsingJMSTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -76,9 +76,9 @@
public void testGetAttributes() throws Exception
{
- assertEquals(topic.getTopicName(), proxy.retrieveAttributeValue("Name"));
- assertEquals(topic.getAddress(), proxy.retrieveAttributeValue("Address"));
- assertEquals(topic.isTemporary(), proxy.retrieveAttributeValue("Temporary"));
+ assertEquals(topic.getTopicName(), proxy.retrieveAttributeValue("name"));
+ assertEquals(topic.getAddress(), proxy.retrieveAttributeValue("address"));
+ assertEquals(topic.isTemporary(), proxy.retrieveAttributeValue("temporary"));
assertEquals(topic.getName(), proxy.retrieveAttributeValue("JNDIBinding"));
}
@@ -94,9 +94,9 @@
Connection connection_3 = JMSUtil.createConnection(InVMConnectorFactory.class.getName());
JMSUtil.createDurableSubscriber(connection_3, topic, clientID, subscriptionName + "2");
- assertEquals(3, proxy.retrieveAttributeValue("SubscriptionCount"));
- assertEquals(1, proxy.retrieveAttributeValue("NonDurableSubscriptionCount"));
- assertEquals(2, proxy.retrieveAttributeValue("DurableSubscriptionCount"));
+ assertEquals(3, proxy.retrieveAttributeValue("subscriptionCount"));
+ assertEquals(1, proxy.retrieveAttributeValue("nonDurableSubscriptionCount"));
+ assertEquals(2, proxy.retrieveAttributeValue("durableSubscriptionCount"));
connection_1.close();
connection_2.close();
@@ -113,15 +113,15 @@
Connection connection_3 = JMSUtil.createConnection(InVMConnectorFactory.class.getName());
JMSUtil.createDurableSubscriber(connection_3, topic, clientID, subscriptionName + "2");
- assertEquals(0, proxy.retrieveAttributeValue("MessageCount"));
- assertEquals(0, proxy.retrieveAttributeValue("NonDurableMessageCount"));
- assertEquals(0, proxy.retrieveAttributeValue("DurableMessageCount"));
+ assertEquals(0, proxy.retrieveAttributeValue("messageCount"));
+ assertEquals(0, proxy.retrieveAttributeValue("nonDurableMessageCount"));
+ assertEquals(0, proxy.retrieveAttributeValue("durableMessageCount"));
JMSUtil.sendMessages(topic, 2);
- assertEquals(3 * 2, proxy.retrieveAttributeValue("MessageCount"));
- assertEquals(1 * 2, proxy.retrieveAttributeValue("NonDurableMessageCount"));
- assertEquals(2 * 2, proxy.retrieveAttributeValue("DurableMessageCount"));
+ assertEquals(3 * 2, proxy.retrieveAttributeValue("messageCount"));
+ assertEquals(1 * 2, proxy.retrieveAttributeValue("nonDurableMessageCount"));
+ assertEquals(2 * 2, proxy.retrieveAttributeValue("durableMessageCount"));
connection_1.close();
connection_2.close();
@@ -162,7 +162,7 @@
JMSUtil.sendMessageWithProperty(session, topic, key, unmatchingValue);
JMSUtil.sendMessageWithProperty(session, topic, key, matchingValue);
- assertEquals(3, proxy.retrieveAttributeValue("MessageCount"));
+ assertEquals(3, proxy.retrieveAttributeValue("messageCount"));
assertEquals(2, proxy.invokeOperation("countMessagesForSubscription", clientID, subscriptionName, key + " =" +
matchingValue));
@@ -207,13 +207,13 @@
JMSUtil.createDurableSubscriber(connection, topic, clientID, subscriptionName);
- assertEquals(1, proxy.retrieveAttributeValue("DurableSubscriptionCount"));
+ assertEquals(1, proxy.retrieveAttributeValue("durableSubscriptionCount"));
connection.close();
proxy.invokeOperation("dropDurableSubscription", clientID, subscriptionName);
- assertEquals(0, proxy.retrieveAttributeValue("DurableSubscriptionCount"));
+ assertEquals(0, proxy.retrieveAttributeValue("durableSubscriptionCount"));
}
public void testDropDurableSubscriptionWithUnknownSubscription() throws Exception
@@ -222,7 +222,7 @@
JMSUtil.createDurableSubscriber(connection, topic, clientID, subscriptionName);
- assertEquals(1, proxy.retrieveAttributeValue("DurableSubscriptionCount"));
+ assertEquals(1, proxy.retrieveAttributeValue("durableSubscriptionCount"));
try
{
@@ -234,7 +234,7 @@
}
- assertEquals(1, proxy.retrieveAttributeValue("DurableSubscriptionCount"));
+ assertEquals(1, proxy.retrieveAttributeValue("durableSubscriptionCount"));
connection.close();
}
@@ -252,15 +252,15 @@
clientID,
subscriptionName + "2");
- assertEquals(2, proxy.retrieveAttributeValue("SubscriptionCount"));
+ assertEquals(2, proxy.retrieveAttributeValue("subscriptionCount"));
durableSubscriber_1.close();
durableSubscriber_2.close();
- assertEquals(2, proxy.retrieveAttributeValue("SubscriptionCount"));
+ assertEquals(2, proxy.retrieveAttributeValue("subscriptionCount"));
proxy.invokeOperation("dropAllSubscriptions");
- assertEquals(0, proxy.retrieveAttributeValue("SubscriptionCount"));
+ assertEquals(0, proxy.retrieveAttributeValue("subscriptionCount"));
connection_1.close();
connection_2.close();
@@ -275,11 +275,11 @@
JMSUtil.sendMessages(topic, 3);
- assertEquals(3 * 2, proxy.retrieveAttributeValue("MessageCount"));
+ assertEquals(3 * 2, proxy.retrieveAttributeValue("messageCount"));
int removedCount = (Integer)proxy.invokeOperation("removeAllMessages");
assertEquals(3 * 2, removedCount);
- assertEquals(0, proxy.retrieveAttributeValue("MessageCount"));
+ assertEquals(0, proxy.retrieveAttributeValue("messageCount"));
connection_1.close();
connection_2.close();
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/AcceptorControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/AcceptorControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/AcceptorControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -68,17 +68,17 @@
public String getFactoryClassName()
{
- return (String)proxy.retrieveAttributeValue("FactoryClassName");
+ return (String)proxy.retrieveAttributeValue("factoryClassName");
}
public String getName()
{
- return (String)proxy.retrieveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("name");
}
public Map<String, Object> getParameters()
{
- return (Map<String, Object>)proxy.retrieveAttributeValue("Parameters");
+ return (Map<String, Object>)proxy.retrieveAttributeValue("parameters");
}
public void pause() throws Exception
@@ -93,7 +93,7 @@
public boolean isStarted()
{
- return (Boolean)proxy.retrieveAttributeValue("Started");
+ return (Boolean)proxy.retrieveAttributeValue("started");
}
public void start() throws Exception
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/AddressControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/AddressControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/AddressControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -79,7 +79,7 @@
CoreMessagingProxy proxy = createProxy(address);
- assertEquals(address.toString(), proxy.retrieveAttributeValue("Address"));
+ assertEquals(address.toString(), proxy.retrieveAttributeValue("address"));
session.deleteQueue(queue);
}
@@ -93,17 +93,17 @@
session.createQueue(address, queue, true);
CoreMessagingProxy proxy = createProxy(address);
- Object[] queueNames = (Object[])proxy.retrieveAttributeValue("QueueNames");
+ Object[] queueNames = (Object[])proxy.retrieveAttributeValue("queueNames");
assertEquals(1, queueNames.length);
assertEquals(queue.toString(), queueNames[0]);
session.createQueue(address, anotherQueue, false);
- queueNames = (Object[])proxy.retrieveAttributeValue("QueueNames");
+ queueNames = (Object[])proxy.retrieveAttributeValue("queueNames");
assertEquals(2, queueNames.length);
session.deleteQueue(queue);
- queueNames = (Object[])proxy.retrieveAttributeValue("QueueNames");
+ queueNames = (Object[])proxy.retrieveAttributeValue("queueNames");
assertEquals(1, queueNames.length);
assertEquals(anotherQueue.toString(), queueNames[0]);
@@ -119,7 +119,7 @@
session.createQueue(address, queue, true);
CoreMessagingProxy proxy = createProxy(address);
- Object[] roles = (Object[])proxy.retrieveAttributeValue("Roles");
+ Object[] roles = (Object[])proxy.retrieveAttributeValue("roles");
for (int i = 0; i < roles.length; i++)
{
System.out.println(((Object[])roles[i])[0]);
@@ -130,7 +130,7 @@
newRoles.add(role);
server.getSecurityRepository().addMatch(address.toString(), newRoles);
- roles = (Object[])proxy.retrieveAttributeValue("Roles");
+ roles = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(1, roles.length);
Object[] r = (Object[])roles[0];
assertEquals(role.getName(), r[0]);
@@ -154,7 +154,7 @@
session.createQueue(address, queue, true);
CoreMessagingProxy proxy = createProxy(address);
- Object[] roles = (Object[])proxy.retrieveAttributeValue("Roles");
+ Object[] roles = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(0, roles.length);
proxy.invokeOperation("addRole", role.getName(),
@@ -166,7 +166,7 @@
CheckType.DELETE_NON_DURABLE_QUEUE.hasRole(role),
CheckType.MANAGE.hasRole(role));
- roles = (Object[])proxy.retrieveAttributeValue("Roles");
+ roles = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(1, roles.length);
Object[] r = (Object[])roles[0];
assertEquals(role.getName(), r[0]);
@@ -192,7 +192,7 @@
session.createQueue(address, queue, true);
CoreMessagingProxy proxy = createProxy(address);
- Object[] data = (Object[])proxy.retrieveAttributeValue("Roles");
+ Object[] data = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(0, data.length);
proxy.invokeOperation("addRole", role.getName(),
@@ -204,7 +204,7 @@
CheckType.DELETE_NON_DURABLE_QUEUE.hasRole(role),
CheckType.MANAGE.hasRole(role));
- data = (Object[])proxy.retrieveAttributeValue("Roles");
+ data = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(1, data.length);
try
@@ -223,7 +223,7 @@
{
}
- data = (Object[])proxy.retrieveAttributeValue("Roles");
+ data = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(1, data.length);
session.deleteQueue(queue);
@@ -238,17 +238,17 @@
session.createQueue(address, queue, true);
CoreMessagingProxy proxy = createProxy(address);
- Object[] data = (Object[])proxy.retrieveAttributeValue("Roles");
+ Object[] data = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(0, data.length);
proxy.invokeOperation("addRole", roleName, randomBoolean(), randomBoolean(), randomBoolean(), randomBoolean(), randomBoolean(), randomBoolean(), randomBoolean());
- data = (Object[])proxy.retrieveAttributeValue("Roles");
+ data = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(1, data.length);
proxy.invokeOperation("removeRole", roleName);
- data = (Object[])proxy.retrieveAttributeValue("Roles");
+ data = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(0, data.length);
session.deleteQueue(queue);
@@ -263,7 +263,7 @@
session.createQueue(address, queue, true);
CoreMessagingProxy proxy = createProxy(address);
- Object[] data = (Object[])proxy.retrieveAttributeValue("Roles");
+ Object[] data = (Object[])proxy.retrieveAttributeValue("roles");
assertEquals(0, data.length);
try
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/BridgeControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/BridgeControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/BridgeControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -82,22 +82,22 @@
checkResource(ObjectNames.getBridgeObjectName(bridgeConfig.getName()));
CoreMessagingProxy proxy = createProxy(bridgeConfig.getName());
- assertEquals(bridgeConfig.getName(), (String)proxy.retrieveAttributeValue("Name"));
- assertEquals(bridgeConfig.getDiscoveryGroupName(), (String)proxy.retrieveAttributeValue("DiscoveryGroupName"));
- assertEquals(bridgeConfig.getQueueName(), (String)proxy.retrieveAttributeValue("QueueName"));
- assertEquals(bridgeConfig.getForwardingAddress(), (String)proxy.retrieveAttributeValue("ForwardingAddress"));
- assertEquals(bridgeConfig.getFilterString(), (String)proxy.retrieveAttributeValue("FilterString"));
- assertEquals(bridgeConfig.getRetryInterval(), ((Long)proxy.retrieveAttributeValue("RetryInterval")).longValue());
- assertEquals(bridgeConfig.getRetryIntervalMultiplier(), (Double)proxy.retrieveAttributeValue("RetryIntervalMultiplier"));
- assertEquals(bridgeConfig.getReconnectAttempts(), ((Integer)proxy.retrieveAttributeValue("ReconnectAttempts")).intValue());
- assertEquals(bridgeConfig.isFailoverOnServerShutdown(), ((Boolean)proxy.retrieveAttributeValue("FailoverOnServerShutdown")).booleanValue());
- assertEquals(bridgeConfig.isUseDuplicateDetection(), ((Boolean)proxy.retrieveAttributeValue("UseDuplicateDetection")).booleanValue());
+ assertEquals(bridgeConfig.getName(), (String)proxy.retrieveAttributeValue("name"));
+ assertEquals(bridgeConfig.getDiscoveryGroupName(), (String)proxy.retrieveAttributeValue("discoveryGroupName"));
+ assertEquals(bridgeConfig.getQueueName(), (String)proxy.retrieveAttributeValue("queueName"));
+ assertEquals(bridgeConfig.getForwardingAddress(), (String)proxy.retrieveAttributeValue("forwardingAddress"));
+ assertEquals(bridgeConfig.getFilterString(), (String)proxy.retrieveAttributeValue("filterString"));
+ assertEquals(bridgeConfig.getRetryInterval(), ((Long)proxy.retrieveAttributeValue("retryInterval")).longValue());
+ assertEquals(bridgeConfig.getRetryIntervalMultiplier(), (Double)proxy.retrieveAttributeValue("retryIntervalMultiplier"));
+ assertEquals(bridgeConfig.getReconnectAttempts(), ((Integer)proxy.retrieveAttributeValue("reconnectAttempts")).intValue());
+ assertEquals(bridgeConfig.isFailoverOnServerShutdown(), ((Boolean)proxy.retrieveAttributeValue("failoverOnServerShutdown")).booleanValue());
+ assertEquals(bridgeConfig.isUseDuplicateDetection(), ((Boolean)proxy.retrieveAttributeValue("useDuplicateDetection")).booleanValue());
- Object[] data = (Object[])proxy.retrieveAttributeValue("ConnectorPair");
+ Object[] data = (Object[])proxy.retrieveAttributeValue("connectorPair");
assertEquals(bridgeConfig.getConnectorPair().a, data[0]);
assertEquals(bridgeConfig.getConnectorPair().b, data[1]);
- assertTrue((Boolean)proxy.retrieveAttributeValue("Started"));
+ assertTrue((Boolean)proxy.retrieveAttributeValue("started"));
}
public void testStartStop() throws Exception
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/BroadcastGroupControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/BroadcastGroupControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/BroadcastGroupControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -66,42 +66,42 @@
public long getBroadcastPeriod()
{
- return ((Integer)proxy.retrieveAttributeValue("BroadcastPeriod")).longValue();
+ return ((Integer)proxy.retrieveAttributeValue("broadcastPeriod")).longValue();
}
public Object[] getConnectorPairs()
{
- return (Object[])proxy.retrieveAttributeValue("ConnectorPairs");
+ return (Object[])proxy.retrieveAttributeValue("connectorPairs");
}
public String getConnectorPairsAsJSON()
{
- return (String)proxy.retrieveAttributeValue("ConnectorPairsAsJSON");
+ return (String)proxy.retrieveAttributeValue("connectorPairsAsJSON");
}
public String getGroupAddress()
{
- return (String)proxy.retrieveAttributeValue("GroupAddress");
+ return (String)proxy.retrieveAttributeValue("groupAddress");
}
public int getGroupPort()
{
- return (Integer)proxy.retrieveAttributeValue("GroupPort");
+ return (Integer)proxy.retrieveAttributeValue("groupPort");
}
public int getLocalBindPort()
{
- return (Integer)proxy.retrieveAttributeValue("LocalBindPort");
+ return (Integer)proxy.retrieveAttributeValue("localBindPort");
}
public String getName()
{
- return (String)proxy.retrieveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("name");
}
public boolean isStarted()
{
- return (Boolean)proxy.retrieveAttributeValue("Started");
+ return (Boolean)proxy.retrieveAttributeValue("started");
}
public void start() throws Exception
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/ClusterConnectionControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/ClusterConnectionControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/ClusterConnectionControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -66,52 +66,52 @@
public String getAddress()
{
- return (String)proxy.retrieveAttributeValue("Address");
+ return (String)proxy.retrieveAttributeValue("address");
}
public String getDiscoveryGroupName()
{
- return (String)proxy.retrieveAttributeValue("DiscoveryGroupName");
+ return (String)proxy.retrieveAttributeValue("discoveryGroupName");
}
public int getMaxHops()
{
- return (Integer)proxy.retrieveAttributeValue("MaxHops");
+ return (Integer)proxy.retrieveAttributeValue("maxHops");
}
public long getRetryInterval()
{
- return (Long)proxy.retrieveAttributeValue("RetryInterval");
+ return (Long)proxy.retrieveAttributeValue("retryInterval");
}
public Object[] getStaticConnectorNamePairs()
{
- return (Object[])proxy.retrieveAttributeValue("StaticConnectorNamePairs");
+ return (Object[])proxy.retrieveAttributeValue("staticConnectorNamePairs");
}
public String getStaticConnectorNamePairsAsJSON()
{
- return (String)proxy.retrieveAttributeValue("StaticConnectorNamePairsAsJSON");
+ return (String)proxy.retrieveAttributeValue("staticConnectorNamePairsAsJSON");
}
public boolean isDuplicateDetection()
{
- return (Boolean)proxy.retrieveAttributeValue("DuplicateDetection");
+ return (Boolean)proxy.retrieveAttributeValue("duplicateDetection");
}
public boolean isForwardWhenNoConsumers()
{
- return (Boolean)proxy.retrieveAttributeValue("ForwardWhenNoConsumers");
+ return (Boolean)proxy.retrieveAttributeValue("forwardWhenNoConsumers");
}
public String getName()
{
- return (String)proxy.retrieveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("name");
}
public boolean isStarted()
{
- return (Boolean)proxy.retrieveAttributeValue("Started");
+ return (Boolean)proxy.retrieveAttributeValue("started");
}
public void start() throws Exception
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/DiscoveryGroupControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/DiscoveryGroupControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/DiscoveryGroupControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -66,27 +66,27 @@
public String getGroupAddress()
{
- return (String)proxy.retrieveAttributeValue("GroupAddress");
+ return (String)proxy.retrieveAttributeValue("groupAddress");
}
public int getGroupPort()
{
- return (Integer)proxy.retrieveAttributeValue("GroupPort");
+ return (Integer)proxy.retrieveAttributeValue("groupPort");
}
public long getRefreshTimeout()
{
- return (Long)proxy.retrieveAttributeValue("RefreshTimeout");
+ return (Long)proxy.retrieveAttributeValue("refreshTimeout");
}
public String getName()
{
- return (String)proxy.retrieveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("name");
}
public boolean isStarted()
{
- return (Boolean)proxy.retrieveAttributeValue("Started");
+ return (Boolean)proxy.retrieveAttributeValue("started");
}
public void start() throws Exception
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/DivertControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/DivertControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/DivertControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -66,37 +66,37 @@
public String getAddress()
{
- return (String)proxy.retrieveAttributeValue("Address");
+ return (String)proxy.retrieveAttributeValue("address");
}
public String getFilter()
{
- return (String)proxy.retrieveAttributeValue("Filter");
+ return (String)proxy.retrieveAttributeValue("filter");
}
public String getForwardingAddress()
{
- return (String)proxy.retrieveAttributeValue("ForwardingAddress");
+ return (String)proxy.retrieveAttributeValue("forwardingAddress");
}
public String getRoutingName()
{
- return (String)proxy.retrieveAttributeValue("RoutingName");
+ return (String)proxy.retrieveAttributeValue("routingName");
}
public String getTransformerClassName()
{
- return (String)proxy.retrieveAttributeValue("TransformerClassName");
+ return (String)proxy.retrieveAttributeValue("transformerClassName");
}
public String getUniqueName()
{
- return (String)proxy.retrieveAttributeValue("UniqueName");
+ return (String)proxy.retrieveAttributeValue("uniqueName");
}
public boolean isExclusive()
{
- return (Boolean)proxy.retrieveAttributeValue("Exclusive");
+ return (Boolean)proxy.retrieveAttributeValue("exclusive");
}
};
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/ManagementServiceImplTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/ManagementServiceImplTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/ManagementServiceImplTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -146,7 +146,7 @@
ServerMessage message = new ServerMessageImpl();
MessagingBuffer body = ChannelBuffers.buffer(2048);
message.setBody(body);
- ManagementHelper.putAttribute(message, ResourceNames.CORE_SERVER, "Attribute.Does.Not.Exist");
+ ManagementHelper.putAttribute(message, ResourceNames.CORE_SERVER, "attribute.Does.Not.Exist");
ServerMessage reply = server.getManagementService().handleMessage(message);
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/MessagingServerControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/MessagingServerControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/MessagingServerControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -128,37 +128,37 @@
public String getBackupConnectorName()
{
- return (String)proxy.retrieveAttributeValue("BackupConnectorName");
+ return (String)proxy.retrieveAttributeValue("backupConnectorName");
}
public String getBindingsDirectory()
{
- return (String)proxy.retrieveAttributeValue("BindingsDirectory");
+ return (String)proxy.retrieveAttributeValue("bindingsDirectory");
}
public Configuration getConfiguration()
{
- return (Configuration)proxy.retrieveAttributeValue("Configuration");
+ return (Configuration)proxy.retrieveAttributeValue("configuration");
}
public int getConnectionCount()
{
- return (Integer)proxy.retrieveAttributeValue("ConnectionCount");
+ return (Integer)proxy.retrieveAttributeValue("connectionCount");
}
public long getConnectionTTLOverride()
{
- return (Long)proxy.retrieveAttributeValue("ConnectionTTLOverride", Long.class);
+ return (Long)proxy.retrieveAttributeValue("connectionTTLOverride", Long.class);
}
public Object[] getConnectors() throws Exception
{
- return (Object[])proxy.retrieveAttributeValue("Connectors");
+ return (Object[])proxy.retrieveAttributeValue("connectors");
}
public String getConnectorsAsJSON() throws Exception
{
- return (String)proxy.retrieveAttributeValue("ConnectorsAsJSON");
+ return (String)proxy.retrieveAttributeValue("connectorsAsJSON");
}
public int getIDCacheSize()
@@ -168,7 +168,7 @@
public String[] getInterceptorClassNames()
{
- Object[] res = (Object[])proxy.retrieveAttributeValue("InterceptorClassNames");
+ Object[] res = (Object[])proxy.retrieveAttributeValue("interceptorClassNames");
String[] names = new String[res.length];
for (int i = 0; i < res.length; i++)
{
@@ -177,189 +177,179 @@
return names;
}
- public int getJournalBufferReuseSize()
- {
- return (Integer)proxy.retrieveAttributeValue("JournalBufferReuseSize");
- }
-
public String getJournalDirectory()
{
- return (String)proxy.retrieveAttributeValue("JournalDirectory");
+ return (String)proxy.retrieveAttributeValue("journalDirectory");
}
public int getJournalFileSize()
{
- return (Integer)proxy.retrieveAttributeValue("JournalFileSize");
+ return (Integer)proxy.retrieveAttributeValue("journalFileSize");
}
public int getJournalMaxAIO()
{
- return (Integer)proxy.retrieveAttributeValue("JournalMaxAIO");
+ return (Integer)proxy.retrieveAttributeValue("journalMaxAIO");
}
public int getJournalMinFiles()
{
- return (Integer)proxy.retrieveAttributeValue("JournalMinFiles");
+ return (Integer)proxy.retrieveAttributeValue("journalMinFiles");
}
public String getJournalType()
{
- return (String)proxy.retrieveAttributeValue("JournalType");
+ return (String)proxy.retrieveAttributeValue("journalType");
}
public String getLargeMessagesDirectory()
{
- return (String)proxy.retrieveAttributeValue("LargeMessagesDirectory");
+ return (String)proxy.retrieveAttributeValue("largeMessagesDirectory");
}
public String getManagementAddress()
{
- return (String)proxy.retrieveAttributeValue("ManagementAddress");
+ return (String)proxy.retrieveAttributeValue("managementAddress");
}
public String getManagementNotificationAddress()
{
- return (String)proxy.retrieveAttributeValue("ManagementNotificationAddress");
+ return (String)proxy.retrieveAttributeValue("managementNotificationAddress");
}
public long getManagementRequestTimeout()
{
- return (Long)proxy.retrieveAttributeValue("ManagementRequestTimeout", Long.class);
+ return (Long)proxy.retrieveAttributeValue("managementRequestTimeout", Long.class);
}
public int getMessageCounterMaxDayCount()
{
- return (Integer)proxy.retrieveAttributeValue("MessageCounterMaxDayCount");
+ return (Integer)proxy.retrieveAttributeValue("messageCounterMaxDayCount");
}
public long getMessageCounterSamplePeriod()
{
- return (Long)proxy.retrieveAttributeValue("MessageCounterSamplePeriod", Long.class);
+ return (Long)proxy.retrieveAttributeValue("messageCounterSamplePeriod", Long.class);
}
public long getMessageExpiryScanPeriod()
{
- return (Long)proxy.retrieveAttributeValue("MessageExpiryScanPeriod", Long.class);
+ return (Long)proxy.retrieveAttributeValue("messageExpiryScanPeriod", Long.class);
}
public long getMessageExpiryThreadPriority()
{
- return (Long)proxy.retrieveAttributeValue("MessageExpiryThreadPriority", Long.class);
+ return (Long)proxy.retrieveAttributeValue("messageExpiryThreadPriority", Long.class);
}
public String getPagingDirectory()
{
- return (String)proxy.retrieveAttributeValue("PagingDirectory");
+ return (String)proxy.retrieveAttributeValue("pagingDirectory");
}
public int getGlobalPageSize()
{
- return (Integer)proxy.retrieveAttributeValue("GlobalPageSize");
+ return (Integer)proxy.retrieveAttributeValue("globalPageSize");
}
public long getPagingMaxGlobalSizeBytes()
{
- return (Long)proxy.retrieveAttributeValue("PagingMaxGlobalSizeBytes", Long.class);
+ return (Long)proxy.retrieveAttributeValue("pagingMaxGlobalSizeBytes", Long.class);
}
public long getQueueActivationTimeout()
{
- return (Long)proxy.retrieveAttributeValue("QueueActivationTimeout", Long.class);
+ return (Long)proxy.retrieveAttributeValue("queueActivationTimeout", Long.class);
}
public int getScheduledThreadPoolMaxSize()
{
- return (Integer)proxy.retrieveAttributeValue("ScheduledThreadPoolMaxSize");
+ return (Integer)proxy.retrieveAttributeValue("scheduledThreadPoolMaxSize");
}
public int getThreadPoolMaxSize()
{
- return (Integer)proxy.retrieveAttributeValue("ThreadPoolMaxSize");
+ return (Integer)proxy.retrieveAttributeValue("threadPoolMaxSize");
}
public long getSecurityInvalidationInterval()
{
- return (Long)proxy.retrieveAttributeValue("SecurityInvalidationInterval", Long.class);
+ return (Long)proxy.retrieveAttributeValue("securityInvalidationInterval", Long.class);
}
public long getTransactionTimeout()
{
- return (Long)proxy.retrieveAttributeValue("TransactionTimeout", Long.class);
+ return (Long)proxy.retrieveAttributeValue("transactionTimeout", Long.class);
}
public long getTransactionTimeoutScanPeriod()
{
- return (Long)proxy.retrieveAttributeValue("TransactionTimeoutScanPeriod", Long.class);
+ return (Long)proxy.retrieveAttributeValue("transactionTimeoutScanPeriod", Long.class);
}
public String getVersion()
{
- return (String)proxy.retrieveAttributeValue("Version");
+ return (String)proxy.retrieveAttributeValue("version");
}
- public boolean isAllowRouteWhenNoBindings()
- {
- return (Boolean)proxy.retrieveAttributeValue("AllowRouteWhenNoBindings");
- }
-
public boolean isBackup()
{
- return (Boolean)proxy.retrieveAttributeValue("Backup");
+ return (Boolean)proxy.retrieveAttributeValue("backup");
}
public boolean isClustered()
{
- return (Boolean)proxy.retrieveAttributeValue("Clustered");
+ return (Boolean)proxy.retrieveAttributeValue("clustered");
}
public boolean isCreateBindingsDir()
{
- return (Boolean)proxy.retrieveAttributeValue("CreateBindingsDir");
+ return (Boolean)proxy.retrieveAttributeValue("createBindingsDir");
}
public boolean isCreateJournalDir()
{
- return (Boolean)proxy.retrieveAttributeValue("CreateJournalDir");
+ return (Boolean)proxy.retrieveAttributeValue("createJournalDir");
}
public boolean isJournalSyncNonTransactional()
{
- return (Boolean)proxy.retrieveAttributeValue("JournalSyncNonTransactional");
+ return (Boolean)proxy.retrieveAttributeValue("journalSyncNonTransactional");
}
public boolean isJournalSyncTransactional()
{
- return (Boolean)proxy.retrieveAttributeValue("JournalSyncTransactional");
+ return (Boolean)proxy.retrieveAttributeValue("journalSyncTransactional");
}
public boolean isMessageCounterEnabled()
{
- return (Boolean)proxy.retrieveAttributeValue("MessageCounterEnabled");
+ return (Boolean)proxy.retrieveAttributeValue("messageCounterEnabled");
}
public boolean isPersistDeliveryCountBeforeDelivery()
{
- return (Boolean)proxy.retrieveAttributeValue("PersistDeliveryCountBeforeDelivery");
+ return (Boolean)proxy.retrieveAttributeValue("persistDeliveryCountBeforeDelivery");
}
public boolean isPersistIDCache()
{
- return (Boolean)proxy.retrieveAttributeValue("PersistIDCache");
+ return (Boolean)proxy.retrieveAttributeValue("persistIDCache");
}
public boolean isSecurityEnabled()
{
- return (Boolean)proxy.retrieveAttributeValue("SecurityEnabled");
+ return (Boolean)proxy.retrieveAttributeValue("securityEnabled");
}
public boolean isStarted()
{
- return (Boolean)proxy.retrieveAttributeValue("Started");
+ return (Boolean)proxy.retrieveAttributeValue("started");
}
public boolean isWildcardRoutingEnabled()
{
- return (Boolean)proxy.retrieveAttributeValue("WildcardRoutingEnabled");
+ return (Boolean)proxy.retrieveAttributeValue("wildcardRoutingEnabled");
}
public String[] listConnectionIDs() throws Exception
@@ -427,11 +417,6 @@
return (Integer)proxy.retrieveAttributeValue("AIOBufferTimeout");
}
- public boolean isAIOFlushOnSync()
- {
- return (Boolean)proxy.retrieveAttributeValue("AIOFlushOnSync");
- }
-
};
}
// Package protected ---------------------------------------------
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/QueueControlUsingCoreTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/QueueControlUsingCoreTest.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/QueueControlUsingCoreTest.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -96,72 +96,72 @@
public String getAddress()
{
- return (String)proxy.retrieveAttributeValue("Address");
+ return (String)proxy.retrieveAttributeValue("address");
}
public int getConsumerCount()
{
- return (Integer)proxy.retrieveAttributeValue("ConsumerCount");
+ return (Integer)proxy.retrieveAttributeValue("consumerCount");
}
public String getDeadLetterAddress()
{
- return (String)proxy.retrieveAttributeValue("DeadLetterAddress");
+ return (String)proxy.retrieveAttributeValue("deadLetterAddress");
}
public int getDeliveringCount()
{
- return (Integer)proxy.retrieveAttributeValue("DeliveringCount");
+ return (Integer)proxy.retrieveAttributeValue("deliveringCount");
}
public String getExpiryAddress()
{
- return (String)proxy.retrieveAttributeValue("ExpiryAddress");
+ return (String)proxy.retrieveAttributeValue("expiryAddress");
}
public String getFilter()
{
- return (String)proxy.retrieveAttributeValue("Filter");
+ return (String)proxy.retrieveAttributeValue("filter");
}
public int getMessageCount()
{
- return (Integer)proxy.retrieveAttributeValue("MessageCount");
+ return (Integer)proxy.retrieveAttributeValue("messageCount");
}
public int getMessagesAdded()
{
- return (Integer)proxy.retrieveAttributeValue("MessagesAdded");
+ return (Integer)proxy.retrieveAttributeValue("messagesAdded");
}
public String getName()
{
- return (String)proxy.retrieveAttributeValue("Name");
+ return (String)proxy.retrieveAttributeValue("name");
}
public long getPersistenceID()
{
- return (Long)proxy.retrieveAttributeValue("PersistenceID");
+ return (Long)proxy.retrieveAttributeValue("persistenceID");
}
public long getScheduledCount()
{
- return (Long)proxy.retrieveAttributeValue("ScheduledCount", Long.class);
+ return (Long)proxy.retrieveAttributeValue("scheduledCount", Long.class);
}
public boolean isBackup()
{
- return (Boolean)proxy.retrieveAttributeValue("Backup");
+ return (Boolean)proxy.retrieveAttributeValue("backup");
}
public boolean isDurable()
{
- return (Boolean)proxy.retrieveAttributeValue("Durable");
+ return (Boolean)proxy.retrieveAttributeValue("durable");
}
public boolean isTemporary()
{
- return (Boolean)proxy.retrieveAttributeValue("Temporary");
+ return (Boolean)proxy.retrieveAttributeValue("temporary");
}
public Map<String, Object>[] listAllMessages() throws Exception
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/management/SecurityManagementTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/management/SecurityManagementTestBase.java 2009-06-17 05:09:47 UTC (rev 7376)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/management/SecurityManagementTestBase.java 2009-06-17 08:21:46 UTC (rev 7377)
@@ -98,7 +98,7 @@
ClientRequestor requestor = new ClientRequestor(session, DEFAULT_MANAGEMENT_ADDRESS);
ClientMessage mngmntMessage = session.createClientMessage(false);
- ManagementHelper.putAttribute(mngmntMessage, ResourceNames.CORE_SERVER, "Started");
+ ManagementHelper.putAttribute(mngmntMessage, ResourceNames.CORE_SERVER, "started");
ClientMessage reply = requestor.request(mngmntMessage, 500);
if (expectSuccess)
{
More information about the jboss-cvs-commits
mailing list