001/* 002 * Licensed to DuraSpace under one or more contributor license agreements. 003 * See the NOTICE file distributed with this work for additional information 004 * regarding copyright ownership. 005 * 006 * DuraSpace licenses this file to you under the Apache License, 007 * Version 2.0 (the "License"); you may not use this file except in 008 * compliance with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, software 013 * distributed under the License is distributed on an "AS IS" BASIS, 014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 015 * See the License for the specific language governing permissions and 016 * limitations under the License. 017 */ 018package org.fcrepo.jms; 019 020import javax.jms.Destination; 021import javax.jms.JMSException; 022 023/** 024 * Machinery to publish JMS messages when an EventBus 025 * message is received. 026 * 027 * @author barmintor 028 * @author awoods 029 */ 030public class JMSTopicPublisher extends AbstractJMSPublisher { 031 032 private String topicName; 033 034 /** 035 * Create a JMS Topic with the default name of "fedora" 036 */ 037 public JMSTopicPublisher() { 038 this("fedora"); 039 } 040 041 /** 042 * Create a JMS Topic with a configurable name 043 * 044 * @param topicName the name of the topic 045 */ 046 public JMSTopicPublisher(final String topicName) { 047 this.topicName = topicName; 048 } 049 050 protected Destination createDestination() throws JMSException { 051 return jmsSession.createTopic(topicName); 052 } 053}