To configure the hub back-end store and retry policy:

<spring:beans>
    <!-- Any implementation of org.mule.util.store.PartitionableObjectStore can be used as a back-end for the hub -->
    <spring:bean id="hubObjectStore"
                 class="org.mule.util.store.PartitionedInMemoryObjectStore" />
</spring:beans>

<!-- By default, the hub will retry failed operations (like confirming a subscription) every 5 minutes and a maximum of 12 times -->
<PuSH-hub:config objectStore-ref="hubObjectStore" />

Exposing the hub to the outside world is then trivial:

<flow name="hub">
    <http:inbound-endpoint address="http://localhost:8080/hub" />
    <PuSH-hub:hub />
</flow>

If the default configuration values are not acceptable, the hub can be configured to use specific values:

<PuSH-hub:config objectStore-ref="hubObjectStore"
                 retryCount="5"
                 retryFrequency="3600000"
                 defaultLeaseSeconds="86400" />

Implementation Status

Supported:

• Subscription with Synchronous and Asynchronous Verification
• Unsubscription with Synchronous and Asynchronous Verification
• Publisher New Content Notification
• Content Fetch
• Content Distribution
• Authenticated Content Distribution
• Number of subscribers in user agent (including support of X-Hub-On-Behalf-Of)

Not Supported:

• Specific publisher support
• Aggregated Content Distribution

Known Limitations

• Subscriber HTTP interactions time-out is fixed to 15 seconds
• The same retry policy is used for un/subscription verification, content fetch and delivery attempts