[jboss-cvs] JBossAS SVN: r109572 - branches/snmp4j-integration-1.11.1/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test.

[jboss-cvs-commits at lists.jboss.org]

Author: thauser at redhat.com
Date: 2010-11-30 16:36:20 -0500 (Tue, 30 Nov 2010)
New Revision: 109572

Modified:
   branches/snmp4j-integration-1.11.1/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test/NotificationProducerService.java
Log:
updated this class to correctly run set and get operations.

Modified: branches/snmp4j-integration-1.11.1/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test/NotificationProducerService.java
===================================================================
--- branches/snmp4j-integration-1.11.1/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test/NotificationProducerService.java	2010-11-30 21:25:16 UTC (rev 109571)
+++ branches/snmp4j-integration-1.11.1/varia/src/main/java/org/jboss/jmx/adaptor/snmp/test/NotificationProducerService.java	2010-11-30 21:36:20 UTC (rev 109572)
@@ -27,6 +27,7 @@
 import org.jboss.jmx.adaptor.snmp.agent.EventTypes;
 import org.jboss.system.ServiceMBeanSupport;
 import org.snmp4j.CommunityTarget;
+import org.snmp4j.mp.SnmpConstants;
 import org.snmp4j.PDU;
 import org.snmp4j.Snmp;
 import org.snmp4j.Target;
@@ -36,6 +37,7 @@
 import org.snmp4j.smi.TcpAddress;
 import org.snmp4j.smi.UdpAddress;
 import org.snmp4j.smi.VariableBinding;
+import org.snmp4j.smi.*;
 import org.snmp4j.transport.DefaultTcpTransportMapping;
 import org.snmp4j.transport.DefaultUdpTransportMapping;
 
@@ -111,10 +113,18 @@
 	   pdu.setType(PDU.GET);
 	   pdu.add(new VariableBinding(new OID("1.2.3.4.1.3")));
 	   
-	   Target target = new CommunityTarget();
+	   CommunityTarget target = new CommunityTarget();
+	   OctetString community = new OctetString("public");
+	   target.setCommunity(community);
+	   Address targetAddress = GenericAddress.parse("udp:127.0.0.1/1161");
+	   target.setAddress(targetAddress);
+	   target.setRetries(2);
+	   target.setTimeout(2000);
+	   
 	   try {
-		target.setAddress(new UdpAddress(InetAddress.getByName("127.0.0.1"), 1161));//could be 1162
+		
 		DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping();
+		transport.listen();
 		Snmp snmp = new Snmp(transport);
 		ResponseEvent responseEvent = snmp.send(pdu, target);
 		System.out.println("response " + responseEvent.toString()); 
@@ -145,6 +155,46 @@
     * @jmx:managed-operation
     */
    public void set(){
+       PDU pdu = new PDU();
+       OID oidn = new OID("1.3.6.1.2.1.1.1");
+       Variable var = new OctetString("MBean Set Test");
+       VariableBinding varBind = new VariableBinding(oidn, var);
+       pdu.add(varBind);
+       pdu.setType(PDU.SET);
+
+       CommunityTarget target = new CommunityTarget();
+       target.setCommunity(new OctetString("private"));
+       target.setVersion(SnmpConstants.version2c);
+       Address targetAddress = GenericAddress.parse("udp:127.0.0.1/1161");
+       target.setAddress(targetAddress);
+       target.setRetries(2);
+       target.setTimeout(1000);
+       
+       try
+       {
+    	DefaultUdpTransportMapping transport = new DefaultUdpTransportMapping();
+    	transport.listen();
+    	Snmp snmp = new Snmp(transport);
+
+    	ResponseEvent responseEvent = snmp.set(pdu, target);
+
+    	PDU responsePDU = responseEvent.getResponse();
+    	
+    	if (responsePDU == null){
+            System.out.println("Request timed out.");
+    	}
+    	else {
+            System.out.println("Received response "+responsePDU);
+    	}
+    	System.out.println("Peer Address: "+responseEvent.getPeerAddress());
+    	} catch (UnknownHostException e1) {
+            e1.printStackTrace();
+    	} catch (IOException e1) {
+            e1.printStackTrace();
+    	} catch (Exception e) {
+            System.out.println("Some Other exception!!");
+    }
+
 	   
    }