[hornetq-commits] JBoss hornetq SVN: r8172 - in trunk/src/main/org/hornetq/core: settings/impl and 1 other directory.

Author: timfox Date: 2009-10-30 13:42:18 -0400 (Fri, 30 Oct 2009) New Revision: 8172 Added: trunk/src/main/org/hornetq/core/server/impl/CreditsAvailableRunnable.java trunk/src/main/org/hornetq/core/settings/impl/AddressFullMessagePolicy.java Log: mainly producer flow control Added: trunk/src/main/org/hornetq/core/server/impl/CreditsAvailableRunnable.java =================================================================== --- trunk/src/main/org/hornetq/core/server/impl/CreditsAvailableRunnable.java (rev 0) +++ trunk/src/main/org/hornetq/core/server/impl/CreditsAvailableRunnable.java 2009-10-30 17:42:18 UTC (rev 8172) @@ -0,0 +1,26 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ + +package org.hornetq.core.server.impl; + +/** + * A CreditsAvailableRunnable + * + * @author tim + * + * + */ +public interface CreditsAvailableRunnable +{ + public boolean run(int credits); +} Added: trunk/src/main/org/hornetq/core/settings/impl/AddressFullMessagePolicy.java =================================================================== --- trunk/src/main/org/hornetq/core/settings/impl/AddressFullMessagePolicy.java (rev 0) +++ trunk/src/main/org/hornetq/core/settings/impl/AddressFullMessagePolicy.java 2009-10-30 17:42:18 UTC (rev 8172) @@ -0,0 +1,26 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ + +package org.hornetq.core.settings.impl; + +/** + * A AddressFullMessagePolicy + * + * @author Tim Fox + * + * + */ +public enum AddressFullMessagePolicy +{ + DROP, PAGE, BLOCK; +}