001    /**
002     * Copyright 2005-2011 The Kuali Foundation
003     *
004     * Licensed under the Educational Community License, Version 2.0 (the "License");
005     * you may not use this file except in compliance with the License.
006     * You may obtain a copy of the License at
007     *
008     * http://www.opensource.org/licenses/ecl2.php
009     *
010     * Unless required by applicable law or agreed to in writing, software
011     * distributed under the License is distributed on an "AS IS" BASIS,
012     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
013     * See the License for the specific language governing permissions and
014     * limitations under the License.
015     */
016    package org.kuali.rice.ksb.messaging.remotedservices;
017    
018    import java.io.Serializable;
019    
020    import org.kuali.rice.core.api.config.CoreConfigHelper;
021    import org.kuali.rice.ksb.messaging.service.KSBJavaService;
022    
023    
024    public class TestHarnessSharedTopic implements KSBJavaService {
025    
026        public static int CALL_COUNT = 0;
027        public static int CALL_COUNT_NOTIFICATION_THRESHOLD = 0;
028        public static Object LOCK = new Object();
029    
030        public synchronized void invoke(Serializable payLoad) {
031                CALL_COUNT++;
032            System.out.println("!!!TestHarnessSharedTopic called with M.E " + CoreConfigHelper.getApplicationId() + " !!! ");
033            ServiceCallInformationHolder.stuff.put("TestHarnessCalled", Boolean.TRUE);
034            if (CALL_COUNT_NOTIFICATION_THRESHOLD > 0) {
035                if (CALL_COUNT == CALL_COUNT_NOTIFICATION_THRESHOLD) {
036                notifyOnLock();
037                }
038            } else {
039                notifyOnLock();
040            }
041    
042    
043        }
044        
045        public void notifyOnLock() {
046            synchronized (LOCK) {
047                LOCK.notifyAll();
048            }
049        }
050    
051    }