How to use ManagedBeanInvocation class of com.consol.citrus.jmx.model package
Best Citrus code snippet using com.consol.citrus.jmx.model.ManagedBeanInvocation
Source:JmxMessage.java 
...23 * @since 2.524 */25public class JmxMessage extends DefaultMessage {26 /** Model objects */27 private ManagedBeanInvocation mbeanInvocation;28 private ManagedBeanResult mbeanResult;29 private JmxMarshaller marshaller = new JmxMarshaller();30 /**31 * Prevent traditional instantiation.32 */33 private JmxMessage() { super(); }34 /**35 * Constructor initializes new service invocation message.36 * @param mbeanInvocation37 */38 private JmxMessage(ManagedBeanInvocation mbeanInvocation) {39 super(mbeanInvocation);40 this.mbeanInvocation = mbeanInvocation;41 }42 /**43 * Constructor initializes new service result message.44 * @param mbeanResult45 */46 private JmxMessage(ManagedBeanResult mbeanResult) {47 super(mbeanResult);48 this.mbeanResult = mbeanResult;49 }50 public static JmxMessage invocation(String mbean) {51 ManagedBeanInvocation invocation = new ManagedBeanInvocation();52 invocation.setMbean(mbean);53 return new JmxMessage(invocation);54 }55 public static JmxMessage invocation(String objectDomain, String objectName) {56 ManagedBeanInvocation invocation = new ManagedBeanInvocation();57 invocation.setObjectDomain(objectDomain);58 invocation.setObjectName(objectName);59 return new JmxMessage(invocation);60 }61 public static JmxMessage invocation(String objectDomain, String objectKey, String objectValue) {62 ManagedBeanInvocation invocation = new ManagedBeanInvocation();63 invocation.setObjectDomain(objectDomain);64 invocation.setObjectKey(objectKey);65 invocation.setObjectValue(objectValue);66 return new JmxMessage(invocation);67 }68 /**69 * Sets attribute for read operation.70 * @param name71 * @return72 */73 public JmxMessage attribute(String name) {74 return attribute(name, null, null);75 }76 /**77 * Sets attribute for write operation.78 * @param name79 * @param value80 * @return81 */82 public JmxMessage attribute(String name, Object value) {83 return attribute(name, value, value.getClass());84 }85 /**86 * Sets attribute for write operation with custom value type.87 * @param name88 * @param value89 * @param valueType90 * @return91 */92 public JmxMessage attribute(String name, Object value, Class<?> valueType) {93 if (mbeanInvocation == null) {94 throw new CitrusRuntimeException("Invalid access to attribute for JMX message");95 }96 ManagedBeanInvocation.Attribute attribute = new ManagedBeanInvocation.Attribute();97 attribute.setName(name);98 if (value != null) {99 attribute.setValueObject(value);100 attribute.setType(valueType.getName());101 }102 mbeanInvocation.setAttribute(attribute);103 return this;104 }105 /**106 * Sets operation for read write access.107 * @param name108 * @return109 */110 public JmxMessage operation(String name) {111 if (mbeanInvocation == null) {112 throw new CitrusRuntimeException("Invalid access to operation for JMX message");113 }114 ManagedBeanInvocation.Operation operation = new ManagedBeanInvocation.Operation();115 operation.setName(name);116 mbeanInvocation.setOperation(operation);117 return this;118 }119 /**120 * Adds operation parameter.121 * @param arg122 * @return123 */124 public JmxMessage parameter(Object arg) {125 return parameter(arg, arg.getClass());126 }127 /**128 * Adds operation parameter with custom parameter type.129 * @param arg130 * @param argType131 * @return132 */133 public JmxMessage parameter(Object arg, Class<?> argType) {134 if (mbeanInvocation == null) {135 throw new CitrusRuntimeException("Invalid access to operation parameter for JMX message");136 }137 if (mbeanInvocation.getOperation() == null) {138 throw new CitrusRuntimeException("Invalid access to operation parameter before operation was set for JMX message");139 }140 if (mbeanInvocation.getOperation().getParameter() == null) {141 mbeanInvocation.getOperation().setParameter(new ManagedBeanInvocation.Parameter());142 }143 OperationParam operationParam = new OperationParam();144 operationParam.setValueObject(arg);145 operationParam.setType(argType.getName());146 mbeanInvocation.getOperation().getParameter().getParameter().add(operationParam);147 return this;148 }149 public static JmxMessage result(Object value) {150 ManagedBeanResult mbeanResult = new ManagedBeanResult();151 ManagedBeanResult.Object mbeanResultObject = new ManagedBeanResult.Object();152 mbeanResultObject.setValueObject(value);153 mbeanResult.setObject(mbeanResultObject);154 return new JmxMessage(mbeanResult);155 }...
Source:JmxMessageConverter.java
...15 */16package com.consol.citrus.jmx.message;17import com.consol.citrus.context.TestContext;18import com.consol.citrus.jmx.endpoint.JmxEndpointConfiguration;19import com.consol.citrus.jmx.model.ManagedBeanInvocation;20import com.consol.citrus.jmx.model.OperationParam;21import com.consol.citrus.message.*;22import org.springframework.util.StringUtils;23import org.springframework.xml.transform.StringResult;24import javax.xml.transform.Source;25/**26 * @author Christoph Deppisch27 * @since 2.528 */29public class JmxMessageConverter implements MessageConverter<ManagedBeanInvocation, ManagedBeanInvocation, JmxEndpointConfiguration> {30 @Override31 public ManagedBeanInvocation convertOutbound(Message internalMessage, JmxEndpointConfiguration endpointConfiguration, TestContext context) {32 ManagedBeanInvocation serviceInvocation = getServiceInvocation(internalMessage, endpointConfiguration);33 convertOutbound(serviceInvocation, internalMessage, endpointConfiguration, context);34 return serviceInvocation;35 }36 @Override37 public void convertOutbound(ManagedBeanInvocation mBeanInvocation, Message internalMessage, JmxEndpointConfiguration endpointConfiguration, TestContext context) {38 if (internalMessage.getHeader(JmxMessageHeaders.JMX_MBEAN) != null) {39 mBeanInvocation.setMbean(internalMessage.getHeader(JmxMessageHeaders.JMX_MBEAN).toString());40 }41 if (internalMessage.getHeader(JmxMessageHeaders.JMX_OPERATION) != null) {42 ManagedBeanInvocation.Operation operation = new ManagedBeanInvocation.Operation();43 operation.setName(internalMessage.getHeader(JmxMessageHeaders.JMX_OPERATION).toString());44 mBeanInvocation.setOperation(operation);45 }46 if (internalMessage.getHeader(JmxMessageHeaders.JMX_OPERATION_PARAMS) != null) {47 String[] params = StringUtils.commaDelimitedListToStringArray(internalMessage.getHeader(JmxMessageHeaders.JMX_OPERATION_PARAMS).toString());48 for (String param : params) {49 OperationParam operationParam = new OperationParam();50 operationParam.setType(String.class.getName());51 operationParam.setValue(param);52 mBeanInvocation.getOperation().getParameter().getParameter().add(operationParam);53 }54 }55 if (internalMessage.getHeader(JmxMessageHeaders.JMX_ATTRIBUTE) != null) {56 ManagedBeanInvocation.Attribute attribute = new ManagedBeanInvocation.Attribute();57 attribute.setName(internalMessage.getHeader(JmxMessageHeaders.JMX_ATTRIBUTE).toString());58 if (internalMessage.getHeader(JmxMessageHeaders.JMX_ATTRIBUTE_VALUE) != null) {59 attribute.setValue(internalMessage.getHeader(JmxMessageHeaders.JMX_ATTRIBUTE_VALUE).toString());60 }61 if (internalMessage.getHeader(JmxMessageHeaders.JMX_ATTRIBUTE_TYPE) != null) {62 attribute.setType(internalMessage.getHeader(JmxMessageHeaders.JMX_ATTRIBUTE_TYPE).toString());63 }64 mBeanInvocation.setAttribute(attribute);65 }66 if (internalMessage.getHeader(JmxMessageHeaders.JMX_OBJECT_DOMAIN) != null) {67 mBeanInvocation.setObjectDomain(internalMessage.getHeader(JmxMessageHeaders.JMX_OBJECT_DOMAIN).toString());68 }69 if (internalMessage.getHeader(JmxMessageHeaders.JMX_OBJECT_NAME) != null) {70 mBeanInvocation.setObjectName(internalMessage.getHeader(JmxMessageHeaders.JMX_OBJECT_NAME).toString());71 }72 }73 @Override74 public Message convertInbound(ManagedBeanInvocation mBeanInvocation, JmxEndpointConfiguration endpointConfiguration, TestContext context) {75 StringResult payload = new StringResult();76 endpointConfiguration.getMarshaller().marshal(mBeanInvocation, payload);77 Message inbound = new DefaultMessage(payload.toString());78 if (mBeanInvocation.getMbean() != null) {79 inbound.setHeader(JmxMessageHeaders.JMX_MBEAN, mBeanInvocation.getMbean());80 }81 if (mBeanInvocation.getObjectDomain() != null) {82 inbound.setHeader(JmxMessageHeaders.JMX_OBJECT_DOMAIN, mBeanInvocation.getObjectDomain());83 inbound.setHeader(JmxMessageHeaders.JMX_OBJECT_NAME, mBeanInvocation.getObjectName());84 }85 return inbound;86 }87 /**88 * Reads Citrus internal RMI message model object from message payload. Either payload is actually a service invocation object or89 * XML payload String is unmarshalled to proper object representation.90 *91 * @param message92 * @param endpointConfiguration93 * @return94 */95 private ManagedBeanInvocation getServiceInvocation(Message message, JmxEndpointConfiguration endpointConfiguration) {96 Object payload = message.getPayload();97 ManagedBeanInvocation serviceInvocation = null;98 if (payload != null) {99 if (payload instanceof ManagedBeanInvocation) {100 serviceInvocation = (ManagedBeanInvocation) payload;101 } else if (payload != null && StringUtils.hasText(message.getPayload(String.class))) {102 serviceInvocation = (ManagedBeanInvocation) endpointConfiguration.getMarshaller()103 .unmarshal(message.getPayload(Source.class));104 } else {105 serviceInvocation = new ManagedBeanInvocation();106 }107 }108 return serviceInvocation;109 }110}...
Source:JmxServerConfigParser.java
...68 mbeanDefinition.setType(mbeanConfig.type());69 mbeanDefinition.setName(mbeanConfig.name());70 mbeanDefinition.setObjectDomain(mbeanConfig.objectDomain());71 mbeanDefinition.setObjectName(mbeanConfig.objectName());72 List<ManagedBeanInvocation.Operation> mbeanOperations = new ArrayList<>();73 MbeanOperation[] mbeanOperationConfigs = mbeanConfig.operations();74 for (MbeanOperation mbeanOperationConfig : mbeanOperationConfigs) {75 ManagedBeanInvocation.Operation op = new ManagedBeanInvocation.Operation();76 op.setName(mbeanOperationConfig.name());77 Class[] parameter = mbeanOperationConfig.parameter();78 ManagedBeanInvocation.Parameter params = new ManagedBeanInvocation.Parameter();79 for (Class paramType : parameter) {80 OperationParam p = new OperationParam();81 p.setType(paramType.getName());82 params.getParameter().add(p);83 }84 if (!CollectionUtils.isEmpty(params.getParameter())) {85 op.setParameter(params);86 }87 mbeanOperations.add(op);88 }89 mbeanDefinition.setOperations(mbeanOperations);90 List<ManagedBeanInvocation.Attribute> mbeanAttributes = new ArrayList<>();91 MbeanAttribute[] mbeanAttributeConfigs = mbeanConfig.attributes();92 for (MbeanAttribute mbeanAttributeConfig : mbeanAttributeConfigs) {93 ManagedBeanInvocation.Attribute att = new ManagedBeanInvocation.Attribute();94 att.setType(mbeanAttributeConfig.type().getName());95 att.setName(mbeanAttributeConfig.name());96 mbeanAttributes.add(att);97 }98 mbeanDefinition.setAttributes(mbeanAttributes);99 managedBeans.add(mbeanDefinition);100 }101 builder.mbeans(managedBeans);102 if (StringUtils.hasText(annotation.actor())) {103 builder.actor(getReferenceResolver().resolve(annotation.actor(), TestActor.class));104 }105 return builder.initialize().build();106 }107}...
ManagedBeanInvocation
Using AI Code Generation
1package com.consol.citrus.jmx.model;2import java.util.ArrayList;3import java.util.List;4import org.testng.Assert;5import org.testng.annotations.Test;6public class ManagedBeanInvocationTest {7public void testManagedBeanInvocation() {8ManagedBeanInvocation managedBeanInvocation = new ManagedBeanInvocation();9List<ManagedBeanInvocationParameter> parameters = new ArrayList<ManagedBeanInvocationParameter>();10ManagedBeanInvocationParameter parameter = new ManagedBeanInvocationParameter();11parameter.setIndex(0);12parameter.setName("name");13parameter.setType("type");14parameter.setValue("value");15parameters.add(parameter);16managedBeanInvocation.setParameters(parameters);17managedBeanInvocation.setOperationName("operationName");18managedBeanInvocation.setObjectName("objectName");19Assert.assertEquals(managedBeanInvocation.getParameters(), parameters);20Assert.assertEquals(managedBeanInvocation.getOperationName(), "operationName");21Assert.assertEquals(managedBeanInvocation.getObjectName(), "objectName");22Assert.assertEquals(managedBeanInvocation.toString(), "ManagedBeanInvocation [objectName=objectName, operationName=operationName, parameters=[ManagedBeanInvocationParameter [index=0, name=name, type=type, value=value]]]");23}24}25package com.consol.citrus.jmx.model;26import java.util.List;27public class ManagedBeanInvocation {28private String objectName;29private String operationName;30private List<ManagedBeanInvocationParameter> parameters;31public String getObjectName() {32return objectName;33}34public void setObjectName(String objectName) {35this.objectName = objectName;36}37public String getOperationName() {38return operationName;39}40public void setOperationName(String operationName) {41this.operationName = operationName;42}43public List<ManagedBeanInvocationParameter> getParameters() {44return parameters;45}46public void setParameters(List<ManagedBeanInvocationParameter> parameters) {47this.parameters = parameters;48}49public String toString() {50return "ManagedBeanInvocation [objectName=" + objectName + ", operationName=" + operationName + ", parameters=" + parameters + "]";51}52}53package com.consol.citrus.jmx.model;54public class ManagedBeanInvocationParameter {55private int index;56private String name;57private String type;58private String value;59public int getIndex() {60return index;61}62public void setIndex(int index) {63this.index = index;64}65public String getName() {66return name;67}68public void setName(String name) {69this.name = name;70}71public String getType() {72return type;73}74public void setType(String type) {
ManagedBeanInvocation
Using AI Code Generation
1package com.consol.citrus.jmx.model;2import java.io.IOException;3import java.util.ArrayList;4import java.util.List;5import javax.management.MalformedObjectNameException;6import javax.management.ObjectName;7import org.testng.Assert;8import org.testng.annotations.Test;9import org.testng.annotations.BeforeTest;10import org.testng.annotations.AfterTest;11public class ManagedBeanInvocationTest {12 private ManagedBeanInvocation managedBeanInvocation;13 public void setUp() {14 managedBeanInvocation = new ManagedBeanInvocation();15 }16 public void testSetObjectName() throws MalformedObjectNameException {17 ObjectName objectName = new ObjectName("test");18 managedBeanInvocation.setObjectName(objectName);19 Assert.assertEquals(managedBeanInvocation.getObjectName(), objectName);20 }21 public void testSetOperationName() {22 managedBeanInvocation.setOperationName("test");23 Assert.assertEquals(managedBeanInvocation.getOperationName(), "test");24 }25 public void testSetParameters() {26 List<Object> parameters = new ArrayList<Object>();27 managedBeanInvocation.setParameters(parameters);28 Assert.assertEquals(managedBeanInvocation.getParameters(), parameters);29 }30 public void testSetSignature() {31 List<String> signature = new ArrayList<String>();32 managedBeanInvocation.setSignature(signature);33 Assert.assertEquals(managedBeanInvocation.getSignature(), signature);34 }35 public void testSetReturnType() {36 managedBeanInvocation.setReturnType("test");37 Assert.assertEquals(managedBeanInvocation.getReturnType(), "test");38 }39 public void testSetParameterTypes() {40 List<String> parameterTypes = new ArrayList<String>();41 managedBeanInvocation.setParameterTypes(parameterTypes);42 Assert.assertEquals(managedBeanInvocation.getParameterTypes(), parameterTypes);43 }44 public void testSetResult() {45 String result = "test";46 managedBeanInvocation.setResult(result);47 Assert.assertEquals(managedBeanInvocation.getResult(), result);48 }49 public void testSetException() {50 Exception exception = new Exception();51 managedBeanInvocation.setException(exception);52 Assert.assertEquals(managedBeanInvocation.getException(), exception);53 }54 public void tearDown() {55 managedBeanInvocation = null;56 }57}
ManagedBeanInvocation
Using AI Code Generation
1package com.consol.citrus.jmx.model;2import java.io.IOException;3import javax.management.MalformedObjectNameException;4import javax.management.ObjectName;5import org.testng.Assert;6import org.testng.annotations.Test;7import com.consol.citrus.jmx.client.JmxClient;8import com.consol.citrus.jmx.client.JmxClientBuilder;9import com.consol.citrus.jmx.endpoint.JmxEndpoint;10import com.consol.citrus.jmx.endpoint.JmxEndpointBuilder;11import com.consol.citrus.jmx.message.JmxMessage;12import com.consol.citrus.jmx.model.ManagedBeanInvocation;13public class TestJmx {14public void testJmx() throws MalformedObjectNameException, IOException {15JmxEndpoint jmxEndpoint = new JmxEndpointBuilder()16.client(new JmxClientBuilder()17.build())18.objectName(new ObjectName("com.consol.citrus:type=TestRunner"))19.build();20JmxClient jmxClient = jmxEndpoint.createClient();21ManagedBeanInvocation mbi = new ManagedBeanInvocation();22mbi.setOperation("startTest");23mbi.setParameterTypes(new String[] {"java.lang.String"});24mbi.setParameters(new Object[] {"test"});25JmxMessage jmxMessage = new JmxMessage(mbi);26jmxClient.send(jmxMessage);27}28}29package com.consol.citrus.jmx.model;30import java.io.IOException;31import javax.management.MalformedObjectNameException;32import javax.management.ObjectName;33import org.testng.Assert;34import org.testng.annotations.Test;35import com.consol.citrus.jmx.client.JmxClient;36import com.consol.citrus.jmx.client.JmxClientBuilder;37import com.consol.citrus.jmx.endpoint.JmxEndpoint;38import com.consol.citrus.jmx.endpoint.JmxEndpointBuilder;39import com.consol.citrus.jmx.message.JmxMessage;40import com.consol.citrus.jmx.model.ManagedBeanInvocation;41public class TestJmx {42public void testJmx() throws MalformedObjectNameException, IOException {43JmxEndpoint jmxEndpoint = new JmxEndpointBuilder()44.client(new JmxClientBuilder()45.url("service
ManagedBeanInvocation
Using AI Code Generation
1package com.consol.citrus.jmx.model;2import java.lang.reflect.Method;3import javax.management.MBeanServerConnection;4import javax.management.ObjectName;5import org.springframework.beans.factory.annotation.Autowired;6import org.springframework.beans.factory.annotation.Qualifier;7import org.springframework.context.annotation.Bean;8import org.springframework.context.annotation.Configuration;9import org.springframework.context.annotation.ImportResource;10import org.springframework.context.annotation.Lazy;11import org.springframework.context.annotation.PropertySource;12import org.springframework.context.annotation.Scope;13import org.springframework.core.env.Environment;14import org.springframework.integration.annotation.ServiceActivator;15import org.springframework.integration.channel.DirectChannel;16import org.springframework.integration.channel.QueueChannel;17import org.springframework.integration.config.EnableIntegration;18import org.springframework.integration.config.EnableIntegrationManagement;19import org.springframework.integration.config.EnableMessageHistory;20import org.springframework.integration.config.EnableMessageHistoryGraphs;21import org.springframework.integration.config.EnableMessageMonitor;22import org.springframework.integration.config.EnableMessageTracing;23import org.springframework.integration.config.EnablePeriodicTracing;24import org.springframework.integration.config.EnablePublisher;25import org.springframework.integration.config.EnablePublisherEvents;26import org.springframework.integration.config.EnablePublisherMetrics;27import org.springframework.integration.config.EnablePublisherStats;28import org.springframework.integration.config.EnablePublisherTracing;29import org.springframework.integration.config.EnableWireTap;30import org.springframework.integration.config.EnableWireTapEvents;31import org.springframework.integration.config.EnableWireTapMetrics;32import org.springframework.integration.config.EnableWireTapStats;33import org.springframework.integration.config.EnableWireTapTracing;34import org.springframework.integration.config.EnableWireTaps;35import org.springframework.integration.config.EnableWireTapsEvents;36import org.springframework.integration.config.EnableWireTapsMetrics;37import org.springframework.integration.config.EnableWireTapsStats;38import org.springframework.integration.config.EnableWireTapsTracing;39import org.springframework.integration.config.EnableWireTapping;40import org.springframework.integration.config.EnableWireTappingEvents;41import org.springframework.integration.config.EnableWireTappingMetrics;42import org.springframework.integration.config.EnableWireTappingStats;43import org.springframework.integration.config.EnableWireTappingTracing;44import org.springframework.integration.config.EnableWireTapsTracing;45import org.springframework.integration.config.EnableWireTappingTracing;46import
ManagedBeanInvocation
Using AI Code Generation
1package com.consol.citrus.jmx.model;2import java.io.IOException;3import java.util.ArrayList;4import java.util.List;5import org.springframework.context.support.ClassPathXmlApplicationContext;6public class TestJmxClient {7 public static void main(String[] args) throws IOException {8 ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("jmx-client-context.xml");9 JmxClient jmxClient = context.getBean(JmxClient.class);10 ManagedBeanInvocation invocation = new ManagedBeanInvocation();11 invocation.setBeanName("jmxServer");12 invocation.setMethod("sayHello");13 invocation.setArguments(new ArrayList<String>());14 jmxClient.invoke(invocation);15 context.close();16 }17}
Automation Testing Tutorials
Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.
LambdaTest Learning Hubs:
- JUnit Tutorial
- TestNG Tutorial
- Webdriver Tutorial
- WebDriverIO Tutorial
- Protractor Tutorial
- Selenium 4 Tutorial
- Jenkins Tutorial
- NUnit Tutorial
- Jest Tutorial
- Playwright Tutorial
- Cypress Tutorial
- PyTest Tutorial
YouTube
You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.
Run Citrus automation tests on LambdaTest cloud grid
Perform automation testing on 3000+ real desktop and mobile devices online.
Most used methods in ManagedBeanInvocation
- getAttributeValue
- getMbean
- setMbean
- getObjectDomain
- setObjectDomain
- getObjectName
- setObjectName
- getObjectKey
- setObjectKey
- getObjectValue
- setObjectValue
- getOperation
- setOperation
- getAttribute
- setAttribute
- getType
- setType
- getValue
- setValue
- getName
- setName
- getRef
- setRef
- getInnerPath
- setInnerPath
- getValueObject
- setValueObject
- getParamTypes
- getParamValues
- getReturnType
- setReturnType
- getParameter
- setParameter
Try LambdaTest Now !!
Get 100 minutes of automation test minutes FREE!!
Was this article helpful?
