protected void doPublish ( String tenantId , List < T > items , String subscriber , int retryCount , long delay ) throws Exception { String data = mapper . writeValueAsString ( items ) ; TextMessage tm = session . createTextMessage ( data ) ; if ( tenantId != null ) { tm . setStringProperty ( "tenant" , tenantId ) ; } if ( subscriber != null ) { tm . setStringProperty ( "subscriber" , subscriber ) ; } tm . setIntProperty ( "retryCount" , retryCount ) ; if ( delay > 0 ) { tm . setLongProperty ( "_AMQ_SCHED_DELIVERY" , System . currentTimeMillis ( ) + delay ) ; } if ( log . isLoggable ( Level . FINEST ) ) { log . finest ( "Publish: " + tm ) ; } producer . send ( tm ) ; }
This method publishes the supplied items .