# Custom module to stop stream from post variables

**URL:** <https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245>\
**Category:** Wowza Developer Dojo\
**Tags:** wowza-streaming-server-java-api\
**Created:** [February 19, 2014, 2:50pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245 "2014-02-19T14:50:55Z")\
**Posts on this page:** 9\
**Page:** 1

<div class="post-metadata">

**Author:** ![Frank\_Troglauer](https://avatars.discourse-cdn.com/v4/letter/f/779978/32.png) [@Frank\_Troglauer](https://community.wowza.com/u/Frank_Troglauer)\
**Post date:** [February 19, 2014, 2:50pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/1 "2014-02-19T14:50:55Z")

</div>

Good afternoon,

I am attempting to custom code a module that will stop a stream. I got the code working that supposedly stops ip streams but I need it to stop rtmp streams so I was trying to merge them together and somehow got some code messed up. If an advanced coder could look at it I would be much obliged.

```auto
package com.marestare.wms.module;
import java.io.*;
import java.util.List;
import java.util.Map;
import java.util.Iterator;
import java.util.List;
import com.wowza.wms.application.IApplicationInstance;
import com.wowza.wms.http.*;
import com.wowza.wms.logging.*;
import com.wowza.wms.vhost.*;
import com.wowza.wms.amf.*;
import com.wowza.wms.client.*;
import com.wowza.wms.module.*;
import com.wowza.wms.request.*;
import com.wowza.wms.stream.IMediaStream;
public class CamManager extends HTTProvider2Base {
	public void onHTTPRequest(IVHost vhost, IHTTPRequest req, IHTTPResponse resp) {
		if (!doHTTPAuthentication(vhost, req, resp))
			return;
		
		Map<String, List<String>> params = req.getParameterMap();
		
		String action = "";
		String app = "";
		String streamName = "";
		String mediacasterType = "";
		
		
		if (req.getMethod().equalsIgnoreCase("post")) {
			req.parseBodyForParams(true);
		}
		if (params.containsKey("action"))
			action = params.get("action").get(0);
		
		if (params.containsKey("app"))
			app = params.get("app").get(0);
		
		if (params.containsKey("streamName"))
			streamName = params.get("streamName").get(0);
		
		if (params.containsKey("mediacasterType"))
			mediacasterType = params.get("mediacasterType").get(0);
		
		IApplicationInstance appInstance = vhost.getApplication(app).getAppInstance("_definst_");
		
		String report = action + " " + streamName;
		
		try
		{
		if (action.equalsIgnoreCase("start"))
		{
			appInstance.startMediaCasterStream(streamName, mediacasterType);
		} 
		else if (action.equalsIgnoreCase("stop"))
		{
			appInstance.stopMediaCasterStream(streamName);
			
			stopStream();
		}
		}
		catch(Exception e)
		{
			report = e.getMessage();
		}
		
		
		String retStr = "<html><head><title>MediaCaster HTTProvider</title></head><body>" + report + "</body></html>";
		try {
			OutputStream out = resp.getOutputStream();
			byte[] outBytes = retStr.getBytes();
			out.write(outBytes);
		} catch (Exception e) {
			WMSLoggerFactory.getLogger(null).error(
					"MediaCasterHTTP: " + e.toString());
		}
	}
	public stopStream(IClient client, RequestFunction function,
			AMFDataList params) {
		
		String streamName = getParamString(params, PARAM1);
		
		List<String> published = client.getAppInstance().getPublishStreamNames();
		Iterator iter = published.iterator();
		while (iter.hasNext())
		{
			IMediaStream publishstream = (IMediaStream )iter.next();
			if (publishstream.getName().equalsIgnoreCase(streamName))
			{
				publishstream.getClient().setShutdownClient(true);
			}
		}
	}
}

```

---

<div class="post-metadata">

**Author:** ![Roger\_Littin1](https://avatars.discourse-cdn.com/v4/letter/r/c89c15/32.png) [@Roger\_Littin1](https://community.wowza.com/u/Roger_Littin1)\
**Post date:** [February 20, 2014, 10:14am UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/2 "2014-02-20T10:14:27Z")

</div>

Hi,

Your onHTTPRequest method is a HTTPProvider method and your stopStream method is a Application Module method.

You need to re-write your stopStream method so that it does not have references to IClient client, RequestFunction function, AMFDataList params.

Roger.

---

<div class="post-metadata">

**Author:** ![Richard\_Lanham](https://avatars.discourse-cdn.com/v4/letter/r/c68b51/32.png) [@Richard\_Lanham](https://community.wowza.com/u/Richard_Lanham)\
**Post date:** [May 2, 2014, 10:16pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/3 "2014-05-02T22:16:26Z")

</div>

The MediaCaster types are rtp, rtp-record, liverepeater, shoutcast, shoutcast-record

The most common is rtp for restreaming rtsp and udp sources.

The IDE trick when you see that error is hover over it with your cursor (don’t click, just hover) and look for an option to import, which you can select and the IDE will insert an import statement at top.

Richard

---

<div class="post-metadata">

**Author:** ![Roger\_Littin1](https://avatars.discourse-cdn.com/v4/letter/r/c89c15/32.png) [@Roger\_Littin1](https://community.wowza.com/u/Roger_Littin1)\
**Post date:** [February 22, 2014, 6:42pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/4 "2014-02-22T18:42:52Z")

</div>

Hi,

Something like the following should work.

```auto
	public void onHTTPRequest(IVHost vhost, IHTTPRequest req, IHTTPResponse resp) {
		if (!doHTTPAuthentication(vhost, req, resp))
			return;
		
		Map<String, List<String>> params = req.getParameterMap();
		
		String action = "";
		String app = "";
		String streamName = "";
		String mediacasterType = "";
		
		
		if (req.getMethod().equalsIgnoreCase("post")) {
			req.parseBodyForParams(true);
		}
		if (params.containsKey("action"))
			action = params.get("action").get(0);
		
		if (params.containsKey("app"))
			app = params.get("app").get(0);
		
		if (params.containsKey("streamName"))
			streamName = params.get("streamName").get(0);
		
		if (params.containsKey("mediacasterType"))
			mediacasterType = params.get("mediacasterType").get(0);
		
		IApplicationInstance appInstance = vhost.getApplication(app).getAppInstance("_definst_");
		
		String report = action + " " + streamName;
		
		try
		{
		if (action.equalsIgnoreCase("start"))
		{
			appInstance.startMediaCasterStream(streamName, mediacasterType);
		} 
		else if (action.equalsIgnoreCase("stop"))
		{
			if(appInstance.getMediaCasterStreams().getStreamManager().streamExists(streamName))
			{
				appInstance.stopMediaCasterStream(streamName);
			}
			else
			{
				stopStream(appInstance, streamName);
			}
		}
		}
		catch(Exception e)
		{
			report = e.getMessage();
		}
		
		
		String retStr = "<html><head><title>MediaCaster HTTProvider</title></head><body>" + report + "</body></html>";
		try {
			OutputStream out = resp.getOutputStream();
			byte[] outBytes = retStr.getBytes();
			out.write(outBytes);
		} catch (Exception e) {
			WMSLoggerFactory.getLogger(null).error(
					"MediaCasterHTTP: " + e.toString());
		}
	}
	private void stopStream(IApplicationInstance appInstance, String streamName)
	{
		// see if there is a published stream called streamName
		IMediaStream stream = appInstance.getStreams().getStream(streamName);
		if(stream != null)
		{
			// if the stream is a rtmp stream then it will have a client so shut it down
			IClient client = stream.getClient();
			if(client != null)
			{
				client.setShutdownClient(true);
				return;
			}
			
			// else, if it is an rtsp stream, shut down the rtsp session
			RTPStream rtpStream = stream.getRTPStream();
			if(rtpStream != null)
			{
				RTPSession session = rtpStream.getSession();
				if(session != null)
				{
					appInstance.getVHost().getRTPContext().shutdownRTPSession(session);
				}
			}
			
			// could also be an internal stream so it should be shut down by the process that started it and not here. e.g. transcoder or StreamPublisher.
		}
	}

```

Roger.

---

<div class="post-metadata">

**Author:** ![Frank\_Troglauer](https://avatars.discourse-cdn.com/v4/letter/f/779978/32.png) [@Frank\_Troglauer](https://community.wowza.com/u/Frank_Troglauer)\
**Post date:** [February 21, 2014, 1:38pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/5 "2014-02-21T13:38:59Z")

</div>

Hey Roger,

Thanks for replying. I am not really sure how to re-write the stopStream without those as they are integral parts of defining a cam stream and stopping it. Could you provide any advise on re-writing it or areas of documentation that may go over in greater detail how?

Thanks.

---

<div class="post-metadata">

**Author:** ![Frank\_Troglauer](https://avatars.discourse-cdn.com/v4/letter/f/779978/32.png) [@Frank\_Troglauer](https://community.wowza.com/u/Frank_Troglauer)\
**Post date:** [May 2, 2014, 4:20pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/6 "2014-05-02T16:20:58Z")

</div>

Hey Roger,

Thanks for answering this so long ago. Unfortunately something came up and I wasn’t able to finish this at the time. I am currently diving back in and redid my learing through the Wowza IDE guide. This is the code I have now based off of your changes. Please let me know if any parts are unnecessary.

```auto
package com.marestare.wms.module;
import java.io.*;
import java.util.List;
import java.util.Map;
import java.util.Iterator;
import java.util.List;
import com.wowza.wms.application.IApplicationInstance;
import com.wowza.wms.http.*;
import com.wowza.wms.logging.*;
import com.wowza.wms.vhost.*;
import com.wowza.wms.amf.*;
import com.wowza.wms.client.*;
import com.wowza.wms.module.*;
import com.wowza.wms.request.*;
import com.wowza.wms.stream.IMediaStream;
import com.wowza.wms.http.*;
import com.wowza.wms.logging.*;
import com.wowza.wms.vhost.*;
public class MyHTTPProvider extends HTTProvider2Base {
	public void onHTTPRequest(IVHost vhost, IHTTPRequest req, IHTTPResponse resp) {
		if (!doHTTPAuthentication(vhost, req, resp))
			return;
		
		Map<String, List<String>> params = req.getParameterMap();
		
		String action = "";
		String app = "";
		String streamName = "";
		String mediacasterType = "";
		
		
		if (req.getMethod().equalsIgnoreCase("post")) {
			req.parseBodyForParams(true);
		}
		if (params.containsKey("action"))
			action = params.get("action").get(0);
		
		if (params.containsKey("app"))
			app = params.get("app").get(0);
		
		if (params.containsKey("streamName"))
			streamName = params.get("streamName").get(0);
		
		if (params.containsKey("mediacasterType"))
			mediacasterType = params.get("mediacasterType").get(0);
		
		IApplicationInstance appInstance = vhost.getApplication(app).getAppInstance("_definst_");
		
		String report = action + " " + streamName;
		
		try
		{
		if (action.equalsIgnoreCase("start"))
		{
			appInstance.startMediaCasterStream(streamName, mediacasterType);
		} 
		else if (action.equalsIgnoreCase("stop"))
		{
			if(appInstance.getMediaCasterStreams().getStreamManager().streamExists(streamName))
			{
				appInstance.stopMediaCasterStream(streamName);
			}
			else
			{
				stopStream(appInstance, streamName);
			}
		}
		}
		catch(Exception e)
		{
			report = e.getMessage();
		}
		
		
		String retStr = "<html><head><title>MediaCaster HTTProvider</title></head><body>" + report + "</body></html>";
		try {
			OutputStream out = resp.getOutputStream();
			byte[] outBytes = retStr.getBytes();
			out.write(outBytes);
		} catch (Exception e) {
			WMSLoggerFactory.getLogger(null).error(
					"MediaCasterHTTP: " + e.toString());
		}
	}
	private void stopStream(IApplicationInstance appInstance, String streamName)
	{
		// see if there is a published stream called streamName
		IMediaStream stream = appInstance.getStreams().getStream(streamName);
		if(stream != null)
		{
			// if the stream is a rtmp stream then it will have a client so shut it down
			IClient client = stream.getClient();
			if(client != null)
			{
				client.setShutdownClient(true);
				return;
			}
			
			// else, if it is an rtsp stream, shut down the rtsp session
			RTPStream rtpStream = stream.getRTPStream();
			if(rtpStream != null)
			{
				RTPSession session = rtpStream.getSession();
				if(session != null)
				{
					appInstance.getVHost().getRTPContext().shutdownRTPSession(session);
				}
			}
			
			// could also be an internal stream so it should be shut down by the process that started it and not here. e.g. transcoder or StreamPublisher.
		}
	}
}

```

Based on that I should be able to add the following code to VHost.xml

```auto
<HTTPProvider>
    <BaseClass>com.marestare.wms.module.MyHTTPProvider</BaseClass>
    <RequestFilters>*myhttpprovider</RequestFilters>
    <AuthenticationMethod>none</AuthenticationMethod>
</HTTPProvider>

```

And then I can use this link to query it, right?

http://[WowzaServerIp]:port(1935)/myhttpprovider

And I would pass through the following variables via POST.

action

app

streamName

mediacasterType

For mediacasterType what should I put?

Is the stopStream portion at the bottom still required?

Valid actions are start and stop correct?

This will disconnect the stream from the server right? I know some streams will auto try to reconnect though.

Thanks again for all of your help!

---

<div class="post-metadata">

**Author:** ![Frank\_Troglauer](https://avatars.discourse-cdn.com/v4/letter/f/779978/32.png) [@Frank\_Troglauer](https://community.wowza.com/u/Frank_Troglauer)\
**Post date:** [May 2, 2014, 4:32pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/7 "2014-05-02T16:32:58Z")

</div>

I forgot to state that two errors are showing up now in the code.

RTPStream cannot be resolved to a type.

RTPSession cannot be resolved to a type.

![](http://i.imgur.com/VPLhmhr.png)

---

<div class="post-metadata">

**Author:** ![Frank\_Troglauer](https://avatars.discourse-cdn.com/v4/letter/f/779978/32.png) [@Frank\_Troglauer](https://community.wowza.com/u/Frank_Troglauer)\
**Post date:** [May 6, 2014, 2:46pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/8 "2014-05-06T14:46:40Z")

</div>

Thanks rrlanham, that was helpful to fix the errors. Any idea about my other questions?

> Hey Roger,
> 
> Thanks for answering this so long ago. Unfortunately something came up and I wasn’t able to finish this at the time. I am currently diving back in and redid my learing through the Wowza IDE guide. This is the code I have now based off of your changes. Please let me know if any parts are unnecessary.
> 
> ```auto
> package com.marestare.wms.module;
> import java.io.*;
> import java.util.List;
> import java.util.Map;
> import java.util.Iterator;
> import java.util.List;
> import com.wowza.wms.application.IApplicationInstance;
> import com.wowza.wms.http.*;
> import com.wowza.wms.logging.*;
> import com.wowza.wms.vhost.*;
> import com.wowza.wms.amf.*;
> import com.wowza.wms.client.*;
> import com.wowza.wms.module.*;
> import com.wowza.wms.request.*;
> import com.wowza.wms.stream.IMediaStream;
> import com.wowza.wms.http.*;
> import com.wowza.wms.logging.*;
> import com.wowza.wms.vhost.*;
> public class MyHTTPProvider extends HTTProvider2Base {
> public void onHTTPRequest(IVHost vhost, IHTTPRequest req, IHTTPResponse resp) {
> if (!doHTTPAuthentication(vhost, req, resp))
> return;
> 		
> Map<String, List<String>> params = req.getParameterMap();
> 		
> String action = "";
> String app = "";
> String streamName = "";
> String mediacasterType = "";
> 		
> 		
> if (req.getMethod().equalsIgnoreCase("post")) {
> req.parseBodyForParams(true);
> }
> if (params.containsKey("action"))
> action = params.get("action").get(0);
> 		
> if (params.containsKey("app"))
> app = params.get("app").get(0);
> 		
> if (params.containsKey("streamName"))
> streamName = params.get("streamName").get(0);
> 		
> if (params.containsKey("mediacasterType"))
> mediacasterType = params.get("mediacasterType").get(0);
> 		
> IApplicationInstance appInstance = vhost.getApplication(app).getAppInstance("_definst_");
> 		
> String report = action + " " + streamName;
> 		
> try
> {
> if (action.equalsIgnoreCase("start"))
> {
> appInstance.startMediaCasterStream(streamName, mediacasterType);
> } 
> else if (action.equalsIgnoreCase("stop"))
> {
> if(appInstance.getMediaCasterStreams().getStreamManager().streamExists(streamName))
> {
> appInstance.stopMediaCasterStream(streamName);
> }
> else
> {
> stopStream(appInstance, streamName);
> }
> }
> }
> catch(Exception e)
> {
> report = e.getMessage();
> }
> 		
> 		
> String retStr = "<html><head><title>MediaCaster HTTProvider</title></head><body>" + report + "</body></html>";
> try {
> OutputStream out = resp.getOutputStream();
> byte[] outBytes = retStr.getBytes();
> out.write(outBytes);
> } catch (Exception e) {
> WMSLoggerFactory.getLogger(null).error(
> "MediaCasterHTTP: " + e.toString());
> }
> }
> private void stopStream(IApplicationInstance appInstance, String streamName)
> {
> // see if there is a published stream called streamName
> IMediaStream stream = appInstance.getStreams().getStream(streamName);
> if(stream != null)
> {
> // if the stream is a rtmp stream then it will have a client so shut it down
> IClient client = stream.getClient();
> if(client != null)
> {
> client.setShutdownClient(true);
> return;
> }
> 			
> // else, if it is an rtsp stream, shut down the rtsp session
> RTPStream rtpStream = stream.getRTPStream();
> if(rtpStream != null)
> {
> RTPSession session = rtpStream.getSession();
> if(session != null)
> {
> appInstance.getVHost().getRTPContext().shutdownRTPSession(session);
> }
> }
> 			
> // could also be an internal stream so it should be shut down by the process that started it and not here. e.g. transcoder or StreamPublisher.
> }
> }
> }
> 
> ```
> 
> Based on that I should be able to add the following code to VHost.xml
> 
> ```auto
> <HTTPProvider>
> <BaseClass>com.marestare.wms.module.MyHTTPProvider</BaseClass>
> <RequestFilters>*myhttpprovider</RequestFilters>
> <AuthenticationMethod>none</AuthenticationMethod>
> </HTTPProvider>
> 
> ```
> 
> And then I can use this link to query it, right?
> 
> http://[WowzaServerIp]:port(1935)/myhttpprovider
> 
> And I would pass through the following variables via POST.
> 
> action
> 
> app
> 
> streamName
> 
> mediacasterType
> 
> For mediacasterType what should I put?
> 
> Is the stopStream portion at the bottom still required?
> 
> Valid actions are start and stop correct?
> 
> This will disconnect the stream from the server right? I know some streams will auto try to reconnect though.
> 
> Thanks again for all of your help!

---

<div class="post-metadata">

**Author:** ![Frank\_Troglauer](https://avatars.discourse-cdn.com/v4/letter/f/779978/32.png) [@Frank\_Troglauer](https://community.wowza.com/u/Frank_Troglauer)\
**Post date:** [May 6, 2014, 2:54pm UTC](https://community.wowza.com/t/custom-module-to-stop-stream-from-post-variables/40245/9 "2014-05-06T14:54:36Z")

</div>

Nevermind, I was correct.

[http://localhost:1935/myhttpprovider?action=stop&app=mymodules&streamName=cam1&mediacasterType=rtsp](http://localhost:1935/myhttpprovider?action=stop&app=mymodules&streamName=cam1&mediacasterType=rtsp)

is an example usage of it.

Is there anyway to have Wowza detect the mediacasterType rather than us specify it?

Also is there a way for Wowza to tell if the stream is active so I don’t try to turn off a stream that isn’t connected?

Thanks!