View Javadoc
1   /*
2    * Copyright 2010 James Pether Sörling
3    *
4    * Licensed under the Apache License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    *
8    *   http://www.apache.org/licenses/LICENSE-2.0
9    *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   *
16   *	$Id$
17   *  $HeadURL$
18  */
19  package com.hack23.cia.service.component.agent.impl.riksdagen.workers;
20  
21  import javax.jms.JMSException;
22  import javax.jms.Message;
23  import javax.jms.MessageListener;
24  import javax.jms.ObjectMessage;
25  
26  import org.slf4j.Logger;
27  import org.slf4j.LoggerFactory;
28  import org.springframework.beans.factory.annotation.Autowired;
29  import org.springframework.stereotype.Service;
30  import org.springframework.transaction.annotation.Transactional;
31  
32  import com.hack23.cia.model.external.riksdagen.dokumentlista.impl.DocumentElement;
33  import com.hack23.cia.service.component.agent.impl.riksdagen.workers.data.RiksdagenUpdateService;
34  
35  /**
36   * The Class RiksdagenDocumentElementWorkConsumerImpl.
37   */
38  @Service("riksdagenDocumentElementWorkConsumerImpl")
39  @Transactional
40  final class RiksdagenDocumentElementWorkConsumerImpl implements
41  MessageListener {
42  
43  	/** The Constant LOGGER. */
44  	private static final Logger LOGGER = LoggerFactory
45  			.getLogger(RiksdagenDocumentElementWorkConsumerImpl.class);
46  
47  	/** The import service. */
48  	@Autowired
49  	private RiksdagenUpdateService updateService;
50  
51  	/**
52  	 * Instantiates a new riksdagen document element work consumer impl.
53  	 */
54  	public RiksdagenDocumentElementWorkConsumerImpl() {
55  		super();
56  	}
57  
58  	@Override
59  	public void onMessage(final Message message) {
60  		try {
61  			updateService.updateDocumentElement((DocumentElement) ((ObjectMessage) message).getObject());
62  		} catch (final RuntimeException | JMSException e) {
63  			LOGGER.warn("Error loading riksdagen document" , e);
64  		}
65  	}
66  }