Class EmailProducer

  • All Implemented Interfaces:
    org.ikasan.spec.component.endpoint.Producer<EmailPayload>, org.ikasan.spec.configuration.Configured<EmailProducerConfiguration>, org.ikasan.spec.configuration.ConfiguredResource<EmailProducerConfiguration>, org.ikasan.spec.management.ManagedResource

    public class EmailProducer
    extends java.lang.Object
    implements org.ikasan.spec.component.endpoint.Producer<EmailPayload>, org.ikasan.spec.management.ManagedResource, org.ikasan.spec.configuration.ConfiguredResource<EmailProducerConfiguration>
    Email Endpoint Producer
    Author:
    Ikasan Development Team
    • Field Detail

      • isCriticalOnStartup

        protected boolean isCriticalOnStartup
        determines whether this managed resource failure will fail the startup of the flow
    • Constructor Detail

      • EmailProducer

        public EmailProducer()
    • Method Detail

      • invoke

        public void invoke​(EmailPayload payload)
                    throws org.ikasan.spec.component.endpoint.EndpointException
        Specified by:
        invoke in interface org.ikasan.spec.component.endpoint.Producer<EmailPayload>
        Throws:
        org.ikasan.spec.component.endpoint.EndpointException
      • getConfiguredResourceId

        public java.lang.String getConfiguredResourceId()
        Specified by:
        getConfiguredResourceId in interface org.ikasan.spec.configuration.ConfiguredResource<EmailProducerConfiguration>
      • setConfiguredResourceId

        public void setConfiguredResourceId​(java.lang.String id)
        Specified by:
        setConfiguredResourceId in interface org.ikasan.spec.configuration.ConfiguredResource<EmailProducerConfiguration>
      • startManagedResource

        public void startManagedResource()
        Specified by:
        startManagedResource in interface org.ikasan.spec.management.ManagedResource
      • stopManagedResource

        public void stopManagedResource()
        Specified by:
        stopManagedResource in interface org.ikasan.spec.management.ManagedResource
      • setManagedResourceRecoveryManager

        public void setManagedResourceRecoveryManager​(org.ikasan.spec.management.ManagedResourceRecoveryManager managedResourceRecoveryManager)
        Specified by:
        setManagedResourceRecoveryManager in interface org.ikasan.spec.management.ManagedResource
      • isCriticalOnStartup

        public boolean isCriticalOnStartup()
        Specified by:
        isCriticalOnStartup in interface org.ikasan.spec.management.ManagedResource
      • setCriticalOnStartup

        public void setCriticalOnStartup​(boolean criticalOnStartup)
        Specified by:
        setCriticalOnStartup in interface org.ikasan.spec.management.ManagedResource