View Javadoc

1   /*
2    * #%L
3    * Bitrepository Access
4    * %%
5    * Copyright (C) 2010 - 2012 The State and University Library, The Royal Library and The State Archives, Denmark
6    * %%
7    * This program is free software: you can redistribute it and/or modify
8    * it under the terms of the GNU Lesser General Public License as 
9    * published by the Free Software Foundation, either version 2.1 of the 
10   * License, or (at your option) any later version.
11   * 
12   * This program is distributed in the hope that it will be useful,
13   * but WITHOUT ANY WARRANTY; without even the implied warranty of
14   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
15   * GNU General Lesser Public License for more details.
16   * 
17   * You should have received a copy of the GNU General Lesser Public 
18   * License along with this program.  If not, see
19   * <http://www.gnu.org/licenses/lgpl-2.1.html>.
20   * #L%
21   */
22  package org.bitrepository.access.getstatus;
23  
24  import org.bitrepository.access.getstatus.conversation.GetStatusConversationContext;
25  import org.bitrepository.access.getstatus.conversation.IdentifyingContributorsForGetStatus;
26  import org.bitrepository.client.AbstractClient;
27  import org.bitrepository.client.conversation.mediator.ConversationMediator;
28  import org.bitrepository.client.eventhandler.EventHandler;
29  import org.bitrepository.common.ArgumentValidator;
30  import org.bitrepository.common.settings.Settings;
31  import org.bitrepository.common.utils.SettingsUtils;
32  import org.bitrepository.protocol.messagebus.MessageBus;
33  import org.slf4j.Logger;
34  import org.slf4j.LoggerFactory;
35  
36  public class ConversationBasedGetStatusClient extends AbstractClient implements GetStatusClient {
37      private final Logger log = LoggerFactory.getLogger(getClass());
38  
39      public ConversationBasedGetStatusClient(
40              MessageBus messageBus,
41              ConversationMediator conversationMediator,
42              Settings settings, String clientID) {
43          super(settings, conversationMediator, messageBus, clientID);
44      }
45  
46      @Override
47      public void getStatus(EventHandler eventHandler) {
48          ArgumentValidator.checkNotNull(eventHandler, "eventHandler");
49          log.info("Requesting status for collection of components.");
50          GetStatusConversationContext context = new GetStatusConversationContext(
51                  settings, messageBus, eventHandler, clientID,
52                  SettingsUtils.getStatusContributorsForCollection());
53          startConversation(context, new IdentifyingContributorsForGetStatus(context));
54      }
55  }