topic Custom action to send jms message in Alfresco Archive https://connect.hyland.com/t5/alfresco-archive/custom-action-to-send-jms-message/m-p/273302#M226432 <HTML><HEAD></HEAD><BODY><SPAN>Hi,</SPAN><BR /><BR /><SPAN>I have created a custom action to send jms message to destination server while any content is updated in the folder.The code is posted below</SPAN><BR /><BR /><BR /><BR /><SPAN>import java.io.ByteArrayOutputStream;</SPAN><BR /><SPAN>import java.io.FileInputStream;</SPAN><BR /><SPAN>import java.io.FileNotFoundException;</SPAN><BR /><BR /><SPAN>import java.io.IOException;</SPAN><BR /><SPAN>import java.util.List;</SPAN><BR /><SPAN>import java.util.Properties;</SPAN><BR /><BR /><SPAN>import javax.naming.Context;</SPAN><BR /><SPAN>import javax.naming.InitialContext;</SPAN><BR /><SPAN>import javax.naming.NamingException;</SPAN><BR /><BR /><SPAN>import javax.jms.BytesMessage;</SPAN><BR /><SPAN>import javax.jms.Connection;</SPAN><BR /><SPAN>import javax.jms.ConnectionFactory;</SPAN><BR /><SPAN>import javax.jms.Destination;</SPAN><BR /><SPAN>import javax.jms.JMSException;</SPAN><BR /><SPAN>import javax.jms.MessageProducer;</SPAN><BR /><SPAN>import javax.jms.Session;</SPAN><BR /><BR /><BR /><SPAN>import org.alfresco.model.ContentModel;</SPAN><BR /><SPAN>import org.alfresco.repo.action.ParameterDefinitionImpl;</SPAN><BR /><SPAN>import org.alfresco.repo.action.executer.ActionExecuterAbstractBase;</SPAN><BR /><SPAN>import org.alfresco.repo.content.ContentServicePolicies;</SPAN><BR /><SPAN>import org.alfresco.repo.policy.Behaviour;</SPAN><BR /><SPAN>import org.alfresco.repo.policy.Behaviour.NotificationFrequency;</SPAN><BR /><SPAN>import org.alfresco.repo.policy.JavaBehaviour;</SPAN><BR /><SPAN>import org.alfresco.repo.policy.PolicyComponent;</SPAN><BR /><SPAN>import org.alfresco.service.cmr.action.Action;</SPAN><BR /><SPAN>import org.alfresco.service.cmr.action.ParameterDefinition;</SPAN><BR /><SPAN>import org.alfresco.service.cmr.dictionary.DataTypeDefinition;</SPAN><BR /><SPAN>import org.alfresco.service.cmr.repository.ContentReader;</SPAN><BR /><SPAN>import org.alfresco.service.cmr.repository.ContentService;</SPAN><BR /><SPAN>import org.alfresco.service.cmr.repository.NodeRef;</SPAN><BR /><SPAN>import org.alfresco.service.cmr.repository.NodeService;</SPAN><BR /><SPAN>import org.alfresco.service.namespace.NamespaceService;</SPAN><BR /><SPAN>import org.alfresco.service.namespace.QName;</SPAN><BR /><BR /><BR /><BR /><SPAN>public class JMSMessageSender&nbsp; extends ActionExecuterAbstractBase implements ContentServicePolicies.OnContentUpdatePolicy{</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;private static final String PROP_KEY_DOCUMENT_ID = null;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;private static final String PROP_KEY_DOCUMENT_NAME = null;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;private static final String PROP_KEY_DOCUMENT_CREATOR = null;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;public final static String PARAM_ACTIVE = "active";</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;// @Resource(mappedName = "jms/GlassFishBookConnetcionFactory")</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp; private ConnectionFactory connectionFactory;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;// @Resource(mappedName = "jms/GlassFishBookQueue") ;&nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;private Behaviour onContentUpdate;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp; private PolicyComponent policyComponent;&nbsp; </SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;MessageProducer messageProducer;&nbsp; </SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;private NodeService nodeService;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;private ContentService contentService;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp; private&nbsp; Session&nbsp; session;</SPAN><BR /><SPAN>&nbsp; &nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;public NodeService getNodeService() {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return nodeService;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;public void setNodeService(NodeService nodeService) {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;this.nodeService = nodeService;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp; public ContentService getContentService() {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return contentService;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;public void setContentService(ContentService contentService) {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;this.contentService = contentService;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;public PolicyComponent getPolicyComponent() {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return policyComponent;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;public void setPolicyComponent(PolicyComponent policyComponent) {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;this.policyComponent = policyComponent;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;public void init(String fileName,String connectionFactoryJNDI,String destinationJNDI)throws NamingException, JMSException, FileNotFoundException, IOException</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp; {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Create behaviours</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.onContentUpdate = new JavaBehaviour(this, "onContentUpdate", NotificationFrequency.TRANSACTION_COMMIT);</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Bind behaviours to policies</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.policyComponent.bindClassBehaviour(QName.createQName(NamespaceService.ALFRESCO_URI, "onContentUpdate"),</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ContentModel.TYPE_CONTENT, this.onContentUpdate);</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Properties properties = new Properties();</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; properties.load(new FileInputStream(fileName));</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Context ctx = new InitialContext(properties);</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Object objHandler = ctx.lookup(connectionFactoryJNDI);</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.connectionFactory = (ConnectionFactory)objHandler;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; objHandler = ctx.lookup(destinationJNDI);</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Destination destination = (Destination)objHandler;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Connection connection = connectionFactory.createConnection();</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; messageProducer = session.createProducer(destination);</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;private void sendJMSEvent(String documentId, String documentName, String user, byte[] documentContent) throws JMSException{</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;@Override</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;protected void executeImpl(Action action, NodeRef actionedUponNodeRef) {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;Boolean flag=true;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;onContentUpdate(actionedUponNodeRef,flag);</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;@Override</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;protected void addParameterDefinitions(List&lt;ParameterDefinition&gt; &nbsp;&nbsp;&nbsp;paramList){</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}</SPAN><BR /><BR /><SPAN>&nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;public void onContentUpdate(NodeRef updatedNodeRef, boolean flag) {</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;</SPAN><BR /><BR /><SPAN>}</SPAN><BR /><SPAN> and the bean is </SPAN><BR /><BR /><SPAN>&lt;bean id="messageSender" class="com.custom.MessageSender" parent="action-executer" init-method="init"&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="nodeService"&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;ref bean="NodeService" /&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/property&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="contentService" &gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;ref bean="ContentService" /&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/property&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;property name="policyComponent"&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;ref bean="PolicyComponent"/&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/property&gt;</SPAN><BR /><SPAN>&nbsp;&nbsp;&nbsp;&lt;/bean&gt;</SPAN><BR /><SPAN>But I am getting error as </SPAN><BR /><SPAN>Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'PolicyComponent' is defined</SPAN><BR /><BR /><SPAN>Can anyboby tell me where I am wrong? Please help.It is urgent.</SPAN></BODY></HTML> Wed, 17 Oct 2012 14:36:02 GMT sradha 2012-10-17T14:36:02Z Custom action to send jms message https://connect.hyland.com/t5/alfresco-archive/custom-action-to-send-jms-message/m-p/273302#M226432 Hi,I have created a custom action to send jms message to destination server while any content is updated in the folder.The code is posted belowimport java.io.ByteArrayOutputStream;import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.IOException;import java.util.List;imp Wed, 17 Oct 2012 14:36:02 GMT https://connect.hyland.com/t5/alfresco-archive/custom-action-to-send-jms-message/m-p/273302#M226432 sradha 2012-10-17T14:36:02Z Re: Custom action to send jms message https://connect.hyland.com/t5/alfresco-archive/custom-action-to-send-jms-message/m-p/273303#M226433 <HTML><HEAD></HEAD><BODY><SPAN>Should probably be policyComponent (lower case p).&nbsp;&nbsp; </SPAN><BR /><BR /><SPAN>Beans beginning with upper case are public services,&nbsp; the policy component is not a service.</SPAN></BODY></HTML> Wed, 17 Oct 2012 16:11:11 GMT https://connect.hyland.com/t5/alfresco-archive/custom-action-to-send-jms-message/m-p/273303#M226433 mrogers 2012-10-17T16:11:11Z