[Openbus-cvs-commits] Openbus/OpenbusJBI/src/java/org/openbus/jbi/messaging DeliveryChannelImpl.java,1.12,1.13 NMRServiceImpl.java,1.7,1.8

[Diego E. <er...@us...>]

Update of /cvsroot/openbus/Openbus/OpenbusJBI/src/java/org/openbus/jbi/messaging
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv23489/src/java/org/openbus/jbi/messaging

Modified Files:
	DeliveryChannelImpl.java NMRServiceImpl.java 
Log Message:
hivemind refactoring

Index: DeliveryChannelImpl.java
===================================================================
RCS file: /cvsroot/openbus/Openbus/OpenbusJBI/src/java/org/openbus/jbi/messaging/DeliveryChannelImpl.java,v
retrieving revision 1.12
retrieving revision 1.13
diff -C2 -d -r1.12 -r1.13
*** DeliveryChannelImpl.java	27 Jun 2005 03:11:57 -0000	1.12
--- DeliveryChannelImpl.java	28 Jun 2005 22:54:44 -0000	1.13
***************
*** 303,308 ****
  		MessageExchangeImpl exchImpl = (MessageExchangeImpl) exchange;
  		exchImpl.getOwnership();
! 		
! 		
  		String msgName = MessageExchangeConstants.OUT_MESSAGE_NAME;
  		exchange.setMessage(reply.getMessage(msgName), msgName);
--- 303,307 ----
  		MessageExchangeImpl exchImpl = (MessageExchangeImpl) exchange;
  		exchImpl.getOwnership();
! 
  		String msgName = MessageExchangeConstants.OUT_MESSAGE_NAME;
  		exchange.setMessage(reply.getMessage(msgName), msgName);
***************
*** 338,343 ****
  	}
  
! 	public void setNmr(NMRService nmr) {
! 		this.nmr = nmr;
  	}
  
--- 337,342 ----
  	}
  
! 	public void setNMRService(NMRService nmr_) {
! 		nmr = nmr_;
  	}
  

Index: NMRServiceImpl.java
===================================================================
RCS file: /cvsroot/openbus/Openbus/OpenbusJBI/src/java/org/openbus/jbi/messaging/NMRServiceImpl.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -C2 -d -r1.7 -r1.8
*** NMRServiceImpl.java	27 Jun 2005 03:11:57 -0000	1.7
--- NMRServiceImpl.java	28 Jun 2005 22:54:44 -0000	1.8
***************
*** 34,38 ****
  import org.openbus.commons.exceptions.OpenbusRuntimeException;
  import org.openbus.jbi.messaging.admin.JMSAdmin;
- import org.openbus.jbi.messaging.admin.JoramJMSAdmin;
  import org.openbus.jbi.servicedesc.ServiceEndpointImpl;
  import org.w3c.dom.Document;
--- 34,37 ----
***************
*** 79,85 ****
  	private JMSAdmin jmsAdmin;
  
! 	public NMRServiceImpl() {
! 		// TODO get implementation from config
! 		jmsAdmin = new JoramJMSAdmin();
  	}
  
--- 78,83 ----
  	private JMSAdmin jmsAdmin;
  
! 	public void setJMSAdmin(JMSAdmin jmsAdmin_) {
! 		jmsAdmin = jmsAdmin_;
  	}
  
***************
*** 254,258 ****
  			dc = new DeliveryChannelImpl(component);
  			// TODO do this in hivemind configuration
! 			((DeliveryChannelImpl)dc).setNmr(this);
  			deliveryChannelByComponent.put(component, dc);
  
--- 252,256 ----
  			dc = new DeliveryChannelImpl(component);
  			// TODO do this in hivemind configuration
! 			((DeliveryChannelImpl) dc).setNMRService(this);
  			deliveryChannelByComponent.put(component, dc);