MessageAddress orig = msg.getOriginator();
MessageAddress orig = msg.getOriginator().getPrimary();
	public MessageAttributes deliverMessage (AttributedMessage msg, MessageAddress dest) 	    throws MisdeliveredMessageException	{ 	    // subscribe to MsglogEnable for remote agents only	    MessageAddress orig = msg.getOriginator();	    if (!getRegistry().isLocalClient(orig)) {		synchronized (agents) {		    AgentEntry entry = (AgentEntry)agents.get(orig);		    if (entry == null) {			entry = new AgentEntry(orig,true);			agents.put(orig, entry);			entry.observer = new AgentObserver(orig); 		    } else {			if (!entry.msglogEnabled) {			    // enabling messaging to any agent that can send me a message			    entry.msglogEnabled = true;			    // this causes message resending to originator to be re-enabled			    if (ackingSvc != null) ackingSvc.release(orig);			    if (eventSvc.isEventEnabled())                         				eventSvc.event("Messaging Enabled from Node " 					       + getRegistry().getIdentifier()					       + " to Agent " 					       + orig);			}		    }		}	    }   	    return super.deliverMessage(msg, dest);	}