История изменений

Исправление bvn13, 03.08.17 12:40 (текущая версия) :

верно. получилось так:

public String enqueueMessage(String queueName, String messageText) {
        try {
            ObjectName name = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=" + queueName);
            QueueViewMBean destinationMBean = (QueueViewMBean) MBeanServerInvocationHandler.newProxyInstance(this.getJmxConnector( ).getMBeanServerConnection( ), name, QueueViewMBean.class, true);

            return destinationMBean.sendTextMessage(messageText);

        } catch (Exception ex) {
            System.out.println(ex.getMessage());
            createJmxConnection();
        }
        return null;
    }

Исходная версия bvn13, 03.08.17 12:39:

верно. получилось так:

public String enqueueMessage(String queueName, String messageText) {
        try {
            ObjectName name = new ObjectName("org.apache.activemq:type=Broker,brokerName=localhost,destinationType=Queue,destinationName=" + queueName);
            QueueViewMBean destinationMBean = (QueueViewMBean) MBeanServerInvocationHandler.newProxyInstance(this.getJmxConnector( ).getMBeanServerConnection( ), name, QueueViewMBean.class, true);

            return destinationMBean.sendTextMessage(messageText);

        } catch (Exception ex) {
            System.out.println(ex.getMessage());
            createJmxConnection();
        }
        return null;
    }
[/java]