Package org.apache.activemq.network

Class NetworkBridgeConfiguration

  • Direct Known Subclasses:
    NetworkConnector
    public class NetworkBridgeConfiguration
extends Object
    Configuration for a NetworkBridge

    • Constructor Detail

      • NetworkBridgeConfiguration

        public NetworkBridgeConfiguration()

    • Method Detail

      • isConduitSubscriptions

        public boolean isConduitSubscriptions()
        Returns:
        the conduitSubscriptions

      • setConduitSubscriptions

        public void setConduitSubscriptions​(boolean conduitSubscriptions)
        Parameters:
        conduitSubscriptions - the conduitSubscriptions to set

      • isConduitNetworkQueueSubscriptions

        public boolean isConduitNetworkQueueSubscriptions()

      • setConduitNetworkQueueSubscriptions

        public void setConduitNetworkQueueSubscriptions​(boolean conduitNetworkQueueSubscriptions)

      • isDynamicOnly

        public boolean isDynamicOnly()
        Returns:
        the dynamicOnly

      • setDynamicOnly

        public void setDynamicOnly​(boolean dynamicOnly)
        Parameters:
        dynamicOnly - the dynamicOnly to set

      • isSyncDurableSubs

        public boolean isSyncDurableSubs()

      • setSyncDurableSubs

        public void setSyncDurableSubs​(boolean syncDurableSubs)

      • isBridgeTempDestinations

        public boolean isBridgeTempDestinations()
        Returns:
        the bridgeTempDestinations

      • setBridgeTempDestinations

        public void setBridgeTempDestinations​(boolean bridgeTempDestinations)
        Parameters:
        bridgeTempDestinations - the bridgeTempDestinations to set

      • isDecreaseNetworkConsumerPriority

        public boolean isDecreaseNetworkConsumerPriority()
        Returns:
        the decreaseNetworkConsumerPriority

      • setDecreaseNetworkConsumerPriority

        public void setDecreaseNetworkConsumerPriority​(boolean decreaseNetworkConsumerPriority)
        Parameters:
        decreaseNetworkConsumerPriority - the decreaseNetworkConsumerPriority to set

      • isDispatchAsync

        public boolean isDispatchAsync()
        Returns:
        the dispatchAsync

      • setDispatchAsync

        public void setDispatchAsync​(boolean dispatchAsync)
        Parameters:
        dispatchAsync - the dispatchAsync to set

      • isDuplex

        public boolean isDuplex()
        Returns:
        the duplex

      • setDuplex

        public void setDuplex​(boolean duplex)
        Parameters:
        duplex - the duplex to set

      • getBrokerName

        public String getBrokerName()
        Returns:
        the brokerName

      • setBrokerName

        public void setBrokerName​(String brokerName)
        Parameters:
        brokerName - the localBrokerName to set

      • getClientIdToken

        public String getClientIdToken()

      • setClientIdToken

        public void setClientIdToken​(String clientIdToken)

      • getNetworkTTL

        public int getNetworkTTL()
        Returns:
        the networkTTL

      • setNetworkTTL

        public void setNetworkTTL​(int networkTTL)
        Parameters:
        networkTTL - the networkTTL to set

      • getPassword

        public String getPassword()
        Returns:
        the password

      • setPassword

        public void setPassword​(String password)
        Parameters:
        password - the password to set

      • getPrefetchSize

        public int getPrefetchSize()
        Returns:
        the prefetchSize

      • setPrefetchSize

        public void setPrefetchSize​(int prefetchSize)
        Parameters:
        prefetchSize - the prefetchSize to set

      • getAdvisoryPrefetchSize

        public int getAdvisoryPrefetchSize()

      • setAdvisoryPrefetchSize

        public void setAdvisoryPrefetchSize​(int advisoryPrefetchSize)
        Prefetch size for advisory consumers. Just like prefetchSize, if set, this value must be greater than 0 because network consumers do not poll for messages. Setting this to 0 or less means this value is disabled and prefetchSize will be used instead.
        Parameters:
        advisoryPrefetchSize -

      • getAdvisoryAckPercentage

        public int getAdvisoryAckPercentage()

      • setAdvisoryAckPercentage

        public void setAdvisoryAckPercentage​(int advisoryAckPercentage)
        Parameters:
        advisoryAckPercentage - the percentage of the advisory prefetch size value that can be dispatched before an ack will be sent, defaults to 75 which means that when the number of received messages is greater than 75% of the prefetch size an ack will be sent back

      • getUserName

        public String getUserName()
        Returns:
        the userName

      • setUserName

        public void setUserName​(String userName)
        Parameters:
        userName - the userName to set

      • getRemoteUserName

        public String getRemoteUserName()
        Returns:
        the remoteUserName

      • setRemoteUserName

        public void setRemoteUserName​(String remoteUserName)
        Parameters:
        remoteUserName - the remoteUserName to set

      • getRemotePassword

        public String getRemotePassword()
        Returns:
        the remotePassword

      • setRemotePassword

        public void setRemotePassword​(String remotePassword)
        Parameters:
        userName - the userName to set

      • getDestinationFilter

        public String getDestinationFilter()
        Returns:
        the destinationFilter

      • setDestinationFilter

        public void setDestinationFilter​(String destinationFilter)
        Parameters:
        destinationFilter - the destinationFilter to set

      • getName

        public String getName()
        Returns:
        the name

      • setName

        public void setName​(String name)
        Parameters:
        name - the name to set

      • setExcludedDestinations

        public void setExcludedDestinations​(List<ActiveMQDestination> excludedDestinations)

      • setDynamicallyIncludedDestinations

        public void setDynamicallyIncludedDestinations​(List<ActiveMQDestination> dynamicallyIncludedDestinations)

      • setStaticallyIncludedDestinations

        public void setStaticallyIncludedDestinations​(List<ActiveMQDestination> staticallyIncludedDestinations)

      • isSuppressDuplicateQueueSubscriptions

        public boolean isSuppressDuplicateQueueSubscriptions()

      • setSuppressDuplicateQueueSubscriptions

        public void setSuppressDuplicateQueueSubscriptions​(boolean val)
        Parameters:
        val - if true, duplicate network queue subscriptions (in a cyclic network) will be suppressed

      • isSuppressDuplicateTopicSubscriptions

        public boolean isSuppressDuplicateTopicSubscriptions()

      • setSuppressDuplicateTopicSubscriptions

        public void setSuppressDuplicateTopicSubscriptions​(boolean val)
        Parameters:
        val - if true, duplicate network topic subscriptions (in a cyclic network) will be suppressed

      • getBrokerURL

        public String getBrokerURL()
        Returns:
        the brokerURL

      • setBrokerURL

        public void setBrokerURL​(String brokerURL)
        Parameters:
        brokerURL - the brokerURL to set

      • isAlwaysSyncSend

        public boolean isAlwaysSyncSend()

      • setAlwaysSyncSend

        public void setAlwaysSyncSend​(boolean alwaysSyncSend)
        Parameters:
        alwaysSyncSend - when true, both persistent and non persistent messages will be sent using a request. When false, non persistent messages are acked once the oneway send succeeds, which can potentially lead to message loss. Using an async request, allows multiple outstanding requests. This ensures that a bridge need not block all sending when the remote broker needs to flow control a single destination.

      • getConsumerPriorityBase

        public int getConsumerPriorityBase()

      • setConsumerPriorityBase

        public void setConsumerPriorityBase​(int consumerPriorityBase)
        Parameters:
        consumerPriorityBase - , default -5. Sets the starting priority for consumers. This base value will be decremented by the length of the broker path when decreaseNetworkConsumerPriority is set.

      • isStaticBridge

        public boolean isStaticBridge()

      • setStaticBridge

        public void setStaticBridge​(boolean staticBridge)

      • setUseCompression

        public void setUseCompression​(boolean useCompression)
        Parameters:
        useCompression - True if the Network should enforce compression for messages sent.

      • isUseCompression

        public boolean isUseCompression()
        Returns:
        the useCompression setting, true if message will be compressed on send.

      • isAdvisoryForFailedForward

        public boolean isAdvisoryForFailedForward()

      • setAdvisoryForFailedForward

        public void setAdvisoryForFailedForward​(boolean advisoryForFailedForward)

      • setConsumerTTL

        public void setConsumerTTL​(int consumerTTL)

      • getConsumerTTL

        public int getConsumerTTL()

      • setMessageTTL

        public void setMessageTTL​(int messageTTL)

      • getMessageTTL

        public int getMessageTTL()

      • isUseBrokerNamesAsIdSeed

        public boolean isUseBrokerNamesAsIdSeed()

      • setUseBrokerNameAsIdSees

        public void setUseBrokerNameAsIdSees​(boolean val)

      • isGcDestinationViews

        public boolean isGcDestinationViews()

      • setGcDestinationViews

        public void setGcDestinationViews​(boolean gcDestinationViews)

      • getGcSweepTime

        public long getGcSweepTime()

      • setGcSweepTime

        public void setGcSweepTime​(long gcSweepTime)

      • isCheckDuplicateMessagesOnDuplex

        public boolean isCheckDuplicateMessagesOnDuplex()

      • setCheckDuplicateMessagesOnDuplex

        public void setCheckDuplicateMessagesOnDuplex​(boolean checkDuplicateMessagesOnDuplex)

      • isUseVirtualDestSubs

        public boolean isUseVirtualDestSubs()

      • setBridgeFactory

        public void setBridgeFactory​(BridgeFactory bridgeFactory)

      • isUseVirtualDestSus

        @Deprecated
public boolean isUseVirtualDestSus()
        Deprecated.
        This was a typo, so this is deprecated as of 5.13.1

      • setUseVirtualDestSubs

        public void setUseVirtualDestSubs​(boolean useVirtualDestSubs)

      • setSslContext

        public void setSslContext​(SslContext sslContext)

      • getSslContext

        public SslContext getSslContext()